Keine Broker verfügbar Fehler beim Versuch, eine Verbindung zu Kafka herzustellen

Question

Ich habe ein sehr merkwürdiges Problem, wenn ich versuche, eine lokale Verbindung zu Kafka 0.10.0.0 mit dem Python-Client auf CentOS herzustellen.

sind meine Verbindungsoptionen ziemlich einfach und Standard:

kafka_consumer = kafka.KafkaConsumer(
     bootstrap_servers=['localhost:9092'], 
     client_id="python-test-consumer" 
    ) 

Wenn ich Zuhörer Option in Kafkas server.properties Datei wie manuell einstellen:

listeners=PLAINTEXT://localhost:9092 

ich den kafka.errors bekommen. NoBrokersAvailable trotz der Tatsache, dass ich immer noch leicht mit Kafka-Broker-Server mit Curl oder anderen Linux-Sachen verbinden kann.

Nein beworbene.listener oder andere veraltete beworbenen Optionen helfen, das Problem zu lösen. Somit ist der einzige Konfigurationszustand, der funktioniert, einer ohne Zuhörer. Was sicherlich nicht akzeptabel ist, da wir den lokalen Cluster irgendwie einrichten müssen.

Es scheint, dass die Lösung für dieses dumme Problem einfach ist und sich wundert, aber wir konnten es nicht selbst herausfinden.

Answer 1

Das klingt vielleicht albern, aber genau das gleiche Problem passiert, weil dieser zu mir:

Ich habe ein Upgrade auf Kafka 0.10.0.0 über Gebräu (Mac Paket-Manager). Brew dann schlägt wie diese Einzeiler zu laufen:

$ zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties; kafka-server-start /usr/local/etc/kafka/server.properties 

Statt, wie ich ausgeführt, bevor:

$ zkServer start 
$ kafka-server-start /usr/local/etc/kafka/server.properties 

Der Ansatz gehalten schlug im Client diese „No Brokers verfügbar“ Fehler werfen. Dann spalte ich den Befehl in zwei Zeilen:

$ zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties 
$ kafka-server-start /usr/local/etc/kafka/server.properties 

Und alles funktioniert wie vorher!

Sorry, wenn das nicht für Sie funktioniert, aber ich dachte, es war erwähnenswert.