我试图用“sasl\u纯文本”或“纯文本”连接合流的kafka代理,但是我得到了这个错误代理传输失败。但是,它可以很好地与“sasl\u ssl”协议配合使用,但不能与任何其他安全协议配合使用。
这是我的密码。
const consumer = new Kafka.KafkaConsumer({
'group.id':'gsuite_consumer',
'metadata.broker.list':*******,
'sasl.mechanisms': 'PLAIN',
'sasl.username':*********,
'sasl.password':******,
'security.protocol': 'PLAINTEXT'
}, {});
// Connect the consumer.
consumer.connect({timeout: "1000ms"}, (err) => {
if (err) {
console.log(`Error connecting to Kafka broker: ${err}`);
process.exit(-1);
}
console.log("Connected to Kafka broker");
});
知道我做错什么了吗?在这里与经纪人联系。我也在heroku服务器上部署了这段代码,但它不起作用
1条答案
按热度按时间ibps3vxo1#
安全协议确定如何建立从客户端到代理的连接。每个(
PLAINTEXT
,SASL_PLAINTEXT
以及SASL_SSL
)工作方式不同,一个端口上只有一个可用。例如,如果你的经纪人用
SASL_SSL
,您需要使用此确切的协议来连接此端口。尝试其他安全协议可能会失败。看一看这个
advertised.listeners
配置代理以识别它们公开的端口/协议组合。