kafka:使用“sasl\u明文”或“明文”协议时代理传输失败

wmomyfyw  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(450)

我试图用“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服务器上部署了这段代码,但它不起作用

ibps3vxo

ibps3vxo1#

安全协议确定如何建立从客户端到代理的连接。每个( PLAINTEXT , SASL_PLAINTEXT 以及 SASL_SSL )工作方式不同,一个端口上只有一个可用。
例如,如果你的经纪人用 SASL_SSL ,您需要使用此确切的协议来连接此端口。尝试其他安全协议可能会失败。
看一看这个 advertised.listeners 配置代理以识别它们公开的端口/协议组合。

相关问题