Kafka 控制台消费者无法连接到 AWS EC2 服务器上的 Zookeeper 服务器答案

【问题标题】：Kafka console consumer not able to connect to zookeeper server on AWS EC2 serverKafka 控制台消费者无法连接到 AWS EC2 服务器上的 Zookeeper 服务器
【发布时间】：2017-10-13 04:05:54
【问题描述】：

我已经在单个 AWS EC2 实例中安装了 kafka 和 zookeeper。我已将服务器的主机名更改为 kafka。当我创建主题时，它运行良好：

/home/kafka/kafka/bin/kafka-topics.sh --create --zookeeper kafka:2181 --replication-factor 1 --partitions 1 --topic test
Created topic "test".

kafka-console-producer.sh 也运行良好：

/home/kafka/kafka/bin# /home/kafka/kafka/bin/kafka-console-producer.sh --broker-list kafka:9092 --topic test
[2017-10-11 20:58:13,924] WARN Property topic is not valid (kafka.utils.VerifiableProperties)
testing

但是kafka生产者超时了：

ubuntu@kafka:~$ /home/kafka/kafka/bin/kafka-console-consumer.sh --zookeeper kafka:9092 --topic test --from-beginning
Exception in thread "main" org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 6000
at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:880)
at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98)
at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84)
at kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:171)
at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:126)
at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:143)
at kafka.consumer.Consumer$.create(ConsumerConnector.scala:94)
at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:145)
at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)

Kafka、zookeeper 和 broker(one) 在同一个 ec2 服务器上运行，并且它们具有默认配置。我在这个安装中遗漏了什么吗？

【问题讨论】：

消费者的 ZooKeeper 端口应该是 2181。
谢谢vahid，您能否将其添加为答案。这有效：/home/kafka/kafka/bin/kafka-console-consumer.sh --zookeeper kafka:2181 --topic test --from-beginning

标签： amazon-ec2 apache-kafka

【解决方案1】：

新的消费者（如生产者）不再连接到 Zookeeper，它只连接到 Kafka。

将命令中的--zookeeper 替换为--bootstrap-server：

/home/kafka/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test --from-beginning

【讨论】：

【解决方案2】：

问题在于，当您使用旧消费者（并使用 --zookeeper 参数）时，应提供 ZooKeeper 端口（@987654322@）。

但是，请注意旧的消费者现在已被弃用，强烈建议使用新的消费者。有关更多信息，请参阅 Mickael Maison 的回答。

【讨论】：