kafka集群controller无法连接broker

Question

我在局域网三台服务器 192.168.51.233，192.168.51.247，192.168.51.223部署了kafka集群使用了sasl_plaintext 认证机制，配置了jaas文件，在使用kafka-topics.sh创建topic报超时错误，深入排查发现，kafka的controller无法连接其他两台broker,但是我用ping 地址和telnet 端口都是通的，每台kafka 服务的listeners 和advertised.listeners配置分别对应服务器ip

“isteners=SASL_PLAINTEXT://192.168.51.233:9092”和“advertised.listeners=SASL_PLAINTEXT://192.168.51.233:9092”；
“listeners=SASL_PLAINTEXT://192.168.51.247:9092”和“advertised.listeners=SASL_PLAINTEXT://192.168.51.247:9092”;
“listeners=SASL_PLAINTEXT://192.168.51.223:9092”和“advertised.listeners=SASL_PLAINTEXT://192.168.51.223:9092”

使用zkCli.sh 可以kafka注册到zookeeper上

controller 日志显示，无法连接其他broker

配置检查了很多遍，尝试了各种方法 无济于事！

Answer 1

从您的问题中，我可以看到您在配置Kafka集群时遇到了连接问题。尽管您已经检查了listeners和advertised.listeners的配置，还有Zookeeper的连接，但似乎Kafka controller无法连接到其他brokers。这里有一些可能的原因和解决方案供您参考：

网络问题：尽管您说ping和telnet都通，但是有可能是网络延迟或丢包等问题导致的连接问题。尝试使用更强大的工具如Netcat或Wireshark来检查网络连接的细节。
端口的配置：请确保Kafka controller可以访问其他brokers的端口。Kafka默认的端口是9092，如果这个端口在您的网络中被阻止，那么Kafka将无法连接。同样，也要确保所有broker的端口配置（例如listeners和advertised.listeners）都是相同的。
防火墙/安全组：检查一下服务器之间的防火墙或安全组规则是否允许Kafka的通信。如果防火墙阻止了Kafka的通信，那么需要修改防火墙规则。
Kafka配置：检查一下所有Kafka broker的配置文件，确保它们都正确地配置了集群的参数。特别注意一下"controller.socket.listeners"和"controller.storage.port"这两个参数是否配置正确。
Zookeeper配置：虽然您提到Zookeeper可以正常工作，但仍然值得检查一下Zookeeper的配置和日志，看看是否有关于Kafka controller的错误信息。
版本兼容性：请确保所有Kafka和Zookeeper的服务都是相同版本，并且相互兼容。
日志分析：查看一下Kafka controller的日志，看看是否有任何错误或警告信息。这可能会提供一些关于问题的线索。
时间同步：由于Kafka会使用时间戳来同步集群，所以确保所有节点的系统时间是准确的。

以上就是一些可能的原因和解决方案，希望能帮助到您。如果问题仍然存在，那么可能需要更深入地检查您的配置和日志。