这是我的制作人,使用kafkajs
。当我在kafkajs
中提供错误的用户名时,我看到消息options.username
。如何使用Connected
处理连接错误?
kafkajs
如果身份验证失败,KafkaJS将在const { Kafka, logLevel } = require('kafkajs')
async function kafkaProducer(options) {
const kafka = new Kafka({
brokers: [options.bootstrapServer],
clientId: options.clientId,
ssl: {
rejectUnauthorized: false,
ca: [fs.readFileSync(options.caCertPath, 'utf-8')]
},
sasl: {
mechanism: options.saslMechanism, // PLAIN
username: options.username,
password: options.password
},
requestTimeout: 2000,
retry: {
retries: 1
},
logLevel: logLevel.ERROR
})
//
const producer = kafka.producer()
try {
await producer.connect()
console.log('Connected')
} catch(e) {
throw new Error(e)
}
}
上引发错误。 connect
。
很可能您没有在代理方正确设置身份验证。 See this test for example,以获取有关如何在代理上配置SASL的信息。