Ich bin neu bei Kafka und versuche, dafür eine Umgebung einzurichten. Ich versuche, einen einzelnen Knoten Kafka zu betreiben, aber ich bekomme Fehler darin.
Folge den Schritten auf dem Mac
%Vor%Aber ich bekomme folgenden Fehler. Bitte lassen Sie mich wissen, wenn ich etwas verpasst habe
%Vor%Danke
Alok, Dieses sehr häufige Problem von Port und Host.
Könnten Sie bitte den HOST und PORT für Zoowärter und Kafka Broker bestätigen. Ich gehe davon aus, Sie haben Kafka in Ihrem lokalen konfiguriert, so stellen Sie sicher, dass Sie richtigen Host-Namen bereitstellen.
Führen Sie den folgenden Befehl aus, um sicherzustellen, dass der Zookeeper und der Kafka Broker auf dem Port laufen, den Sie in Ihrem Befehl erwähnt haben:
netstat -a | grep port
Bitte lassen Sie mich wissen, wenn Sie immer noch Probleme haben.
Das Problem auf meiner Seite wurde gelöst, indem der Wert localhost auf die folgenden Eigenschaften innerhalb der config/server.properties -Datei gesetzt wurde:
Versuchen Sie, den Tierpfleger mit der richtigen Konfiguration wie beim Kafka zu starten:
%Vor%Sie können das Brokerprotokoll löschen und dann erneut versuchen:
%Vor%Wenn Sie immer noch Probleme haben, überprüfen Sie die Protokolle.
Ich habe es gelöst, indem ich die Eigenschaft host.name in der Datei server.properties geändert habe. Standardmäßig ist es auskommentiert und zeigt auf den lokalen Rechner. Also, wenn Sie Kafka lokal starten wollen, kommentieren Sie das einfach aus und Sie sind fertig. Bedeutung - host.name = localhost
Bei der Verwendung eines Kafka-Brokers ist Zoowärter ein Muss.
Sie müssen zookeeper-server starten, bevor Sie kafka-server starten.
Seien Sie sehr vorsichtig mit den Ports, wenn zookeeper port verwendet werden soll, wenn kafka broker port
Wenn Sie eine Ausnahme in Bezug auf Metadaten erhalten, überprüfen Sie, ob Ihr Thema im Broker vorhanden ist.
./kafka-topics.sh --zookeeper <host>:<port> --describe --topic <topic-name>
Für Themen und Verbraucher verwenden Sie den zoekeeper-Port (Dienst) und für den Konsumenten den kafka-Broker.
Tags und Links apache-kafka apache-zookeeper kafka-producer-api