gpt4 book ai didi

node.js - 如何使用任何 Node JS 模块将 Kafka 消费者与 SSL 设置连接起来

转载 作者:太空宇宙 更新时间:2023-11-03 14:26:55 24 4
gpt4 key购买 nike

我想连接供应商提供的外部kafka主题;因为我们已经在 Node JS 之上开发了服务。

所以我在找

NodeJS kafka consumer and with SSL setup;

因为kafka服务器在握手时需要详细信息;

这是我已经用 kafkajs 模块尝试过的

var fs = require('fs');
var Kafka = require('kafkajs').Kafka;
var logLevel = require('kafkajs').logLevel;


var _kafka = new Kafka({
clientId: 'my-app',
brokers: ['broker:9093'],
logLevel: logLevel.DEBUG,
ssl: {
rejectUnauthorized: false,
ca: [fs.readFileSync('./cert/ca.trust.certificate.pem', 'utf-8')],
cert: fs.readFileSync('./cert/client-cert-signed.pem', 'utf-8'),
}
});


try {
const consumer = _kafka.consumer({ groupId: 'test-group' }, { maxWaitTimeInMs: 3000 });

consumer.connect();
consumer.subscribe({ topic: 'external-topic', fromBeginning: true });

consumer.run({
eachMessage: async({ topic, partition, message }) => {
console.log({
partition: 2,
offset: message.offset,
value: message.value.toString(),
})
},
})
} catch (err) {
console.log('Error while connect : ' + err);
}

这是给予

Connection error: 101057795:error:1408E0F4:SSL routines:ssl3_get_message:unexpected message:openssl\ssl\s3_both.c:408:\ while connecting;

能否请您帮助我解决问题或向我推荐任何 npm 模块,以便我可以尝试示例非常欢迎。

最佳答案

忘记在 ssl 选项中添加 key 属性;因为握手时这是强制性的;

关于node.js - 如何使用任何 Node JS 模块将 Kafka 消费者与 SSL 设置连接起来,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56233153/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com