无法建立到节点-1 (localhost/127.0.0.1:2181)的连接。经纪人可能不可用

Question

我试图使用以下命令创建我的第一个主题：

./bin/kafka-topics.sh --bootstrap-server localhost:2181 --create --topic test --partitions 3 --replication-factor 1

然后我得到了下面的错误。

ost:2181 --create --topic test --partitions 3 --replication-factor 1
[2021-10-07 14:03:15,144] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:2181) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2021-10-07 14:03:15,251] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:2181) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2021-10-07 14:03:15,418] WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:2181) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

请你告诉我这里究竟是什么问题，以及如何解决这个问题？

​

​

Answer 1

在Apache文档中，在2.2.0的显著变化下，

bin/kafka-topics.sh 命令行工具现在能够直接连接到使用 --bootstrap-server的代理，而不是动物园管理员。现在，旧的--zookeeper选项仍然可用。有关更多信息，请阅读KIP-377。

(从Apache 3.0.0中删除了--zookeper标志)。

目前还不清楚您使用的是什么版本的Kafka，但是考虑到它接受了标志--bootstrap-server，那么您至少使用了2.2.0 (考虑到dir的名称，可能是< 3.0.0，但对于这个问题并不重要)。

如果您使用的是--bootstrap-server，那么您希望连接到与Kafka服务器相关联的端口，而不是Apache

回想一下

bin/kafka-topics.sh命令行工具现在能够直接连接到代理。

因此，通常使用端口9092，因此您的命令应该是

./bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test --partitions 3 --replication-factor 1

​

但是，--zookeeper通常与端口2181一起使用，因为这是Apache倾向于运行的端口。