kafka安全认证连接问题

Question

[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添加用户密码后出现报错，三个节点都是这种报错，怎么解决啊

Answer 1

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

这个错误是由于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的官方文档，并按照其说明进行操作。