Kafka Broker 可能无法在 127.0.0.1:2181 上使用

Question

我正在尝试使用以下命令运行 kafka 集群：

kafka-topics.sh --bootstrap-server 127.0.0.1:2181 --topic first_topic --create --partitions 3 --replication-factor 1

我得到这个错误：

[2022-02-03 11:25:28,635] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (/127.0.0.1:2181) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

所以我尝试查看 kafka_2.12-3.1.0\config\server.properties 我有

听众=明文://localhost:9092

任何帮助将不胜感激。

Answer 1

2181通常是 ZooKeeper 使用的端口。如果你想指定这一点，并且你没有在 KRaft（无动物园管理员模式）中运行 Kafka，那么你需要按照 @Umeshwaran 所说的那样并使用该--zookeeper参数。

但是，您可以使用--bootstrap-server，但如果您这样做，请指定代理地址和端口，您的侦听器配置中的地址和端口是9092：

kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --topic first_topic --create --partitions 3 --replication-factor 1

这篇文章应该澄清一些事情。