Kafkajs中的多个SSL证书问题。

在Kafkajs中，我们可以使用多个SSL证书来连接到不同的Kafka集群。以下是一个示例

const { Kafka } = require('kafkajs')

const kafka1 = new Kafka({ clientId: 'my-app', brokers: ['kafka1:9093'], ssl: { rejectUnauthorized: false, ca: ['/path/to/ca.crt'], key: ['/path/to/client.key'], cert: ['/path/to/client.crt'] } })

const producer1 = kafka1.producer()

producer1.connect().then(() => { return producer1.send({ topic: 'my-topic', messages: [ { value: 'Hello KafkaJS user!' }, ], }) })

const kafka2 = new Kafka({ clientId: 'my-app', brokers: ['kafka2:9093'], ssl: { rejectUnauthorized: false, ca: ['/path/to/another/ca.crt'], key: ['/path/to/another/client.key'], cert: ['/path/to/another/client.crt'] } })

const producer2 = kafka2.producer()

producer2.connect().then(() => { return producer2.send({ topic: 'my-topic', messages: [ { value: 'Hello again!' }, ], }) })

在上述代码示例中，我们创建了两个不同的Kafka实例（kafka1和kafka2），并配置了它们使用不同的SSL证书（分别是“ca.crt”，“client.key”和“client.crt”以及“another/ca.crt”，“another/client.key”和“another/client.crt”）。然后我们创建了两个不同的生产者（producer1和producer2），并使用每个Kafka实例连接。

这样，我们就能够使用Kafkajs连接到多个Kafka集群，并使用不同的SSL证书进行连接。