kafka consumer kann sich nicht mit seinem zoekeeper verbinden

Ich habe kafka und zookeeper, die in einem Standalone-Modus auf einer ec2-Instanz laufen. Ich habe ein Thema namens dev_spark1 erstellt. Aber wenn ich versuche, Verbraucher von der Kommandozeile ausgeführt werden, gibt mir folgende Fehler für Befehl:kafka consumer kann sich nicht mit seinem zoekeeper verbinden

./bin/kafka-console-consumer.sh --zookeeper 172.31.8.226:9092 --topic dev_spark1

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)

Quelle

2017-03-16 anuja Mandlecha

try Erhöhung zookeeper Verbindung Timeout-Eigenschaft verwenden und überprüfen – mbaxi

Welche Version von kafka verwenden Sie? Können Sie auch DEBUG-Level für Ihre Protokolle hinzufügen? –

Ich habe kafka_2.10-0.8.2.1. Und ich habe das Zeitlimit für die Tierpflegerverbindung von 6000 in der Eigenschaftendatei auf 60000 erhöht, aber das spiegelt sich nicht wider. –

Sind Sie sicher, dass der Zookeeper-Server von der Maschine aus erreichbar ist, auf der Sie kafka haben?

Normalerweise hört der Tierpfleger auf Port 2181 und kafka hört auf Port 9092. In Ihrem Befehl ist es korrekt, wenn Sie versuchen, sich mit dem Tierpfleger auf 172.31.8.226 an Port 9092 zu verbinden.

Anderen Weg, um herauszufinden, ist es, führen Sie diesen Befehl auf Ihrer Tierpfleger Maschine zuerst dann auf dem Kafka-Maschine und prüfen Sie, ob Sie verbinden und Zooweeper ausprobieren können.

bin/zookeeper-shell.sh --zookeeper 172.31.8.226:9092

Wenn Sie die Fähigkeit haben UI zu laufen, können Sie ZooInspector

Quelle

2017-03-17 00:06:23

Zoowärter und Kafka laufen beide auf derselben Maschine. –

Ich bin in der Lage, eine Verbindung zur Tierpfleger-Shell herzustellen und alle Broker und ihre Themen aufzulisten. Aber nur Kafka kann sich nicht mit seinem Tierpfleger verbinden. –

kafka consumer kann sich nicht mit seinem zoekeeper verbinden

Antwort

Verwandte Themen