KafkaコンソールコンシューマがAWS EC2サーバのZookeeperサーバーに接続できません

Question

kookaをzookeeperと一緒に1台のAWS EC2インスタンスにインストールしました。 サーバーのホスト名を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 

しかし、カフカのプロデューサーがタイムアウトされています

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) 

カフカを、zookeeperとブローカー（1つ）は同じec2サーバー上で実行されており、デフォルト構成です。 このインストールで何か不足していますか？

Answer 1

問題は、古いコンシューマを使用（および--zookeeper引数を使用）する場合のZooKeeperポートは（2181）提供されるべきであるということです。

ただし、古いコンシューマは非推奨となりましたので、新しいコンシューマの使用を強くおすすめします。詳細はMickael Maisonの答えをご覧ください。

Answer 2

新しい消費者（プロデューサのような）は、もはや飼い猫に接続せず、カフカにしか接続しません。

は --bootstrap-serverによって、あなたのコマンドで --zookeeperを置き換えます

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