kafka安全认证连接问题

[2023-08-25 17:05:25,820] INFO [SocketServer listenerType=ZK_BROKER, nodeId=1] Failed authentication with /132.251.21.146 (Unexpected Kafka request of type FETCH during SASL handshake.) (org.apache.kafka.common.network.Selector)
[2023-08-25 17:05:26,321] INFO [SocketServer listenerType=ZK_BROKER, nodeId=1] Failed authentication with /132.251.21.146 (Unexpected Kafka request of type FETCH during SASL handshake.) (org.apache.kafka.common.network.Selector)
kafka添加用户密码后出现报错,三个节点都是这种报错,怎么解决啊

引用 皆我百晓生 小程序回复内容作答:

这个错误是由于Kafka在进行SASL握手期间收到了意外的请求类型FETCH导致身份验证失败。可能的原因是配置文件中的某些参数没有正确设置或未正确配置Kafka的SASL认证。

以下是一些可能的解决方案:

  1. 确保将以下属性添加到Kafka配置文件(server.properties)中:

    security.inter.broker.protocol=SASL_PLAINTEXT
    sasl.mechanism.inter.broker.protocol=PLAIN
    sasl.enabled.mechanisms=PLAIN
    

    这些属性将启用Kafka之间的SASL认证和PLAIN机制。

  2. 确保所有Kafka节点的配置文件中的上述属性相同。

  3. 确保配置文件中的其他SASL参数(例如sasl.kerberos.service.name)与您的身份验证配置相匹配。

  4. 检查Kafka的Kerberos配置是否正确并且已在Kafka节点上正确设置。

如果您使用的是其他身份验证机制(如SSL / TLS),请根据您的配置进行相应的调整。

请注意,将安全认证引入Kafka的过程可能颇为复杂,涉及多个步骤和配置文件。建议仔细阅读Kafka的官方文档,并按照其说明进行操作。

【以下回答由 GPT 生成】

对不起,我目前无法提供答案。


如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^