Thema erstellen Apache Kafka

Ich versuche, das Thema in Kafka zu erstellen.Thema erstellen Apache Kafka

Ich folge this Guide, aber es schlägt fehl.

Dieser Fehler ist Error

Error while executing topic command replication factor: 1 larger than available brokers: 0 
kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0 
    at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70) 
    at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:171) 
    at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:93) 
    at kafka.admin.TopicCommand$.main(TopicCommand.scala:55) 
    at kafka.admin.TopicCommand.main(TopicCommand.scala)

Bitte helfen Sie mir, danke.

Quelle

2016-05-05 lam nguyen

Da Sie eine Antwort vom Server erhalten, würde ich beginnen, indem ich die Ausgabe des Befehls untersuchen: bin/kafka-server-start.sh, sollte es wahrscheinlich eine Angabe geben, warum der Broker nicht ausgeführt wurde. Wenn es nicht klar ist, fügen Sie die Ausgabe der Frage hinzu. – erankl

Sie sollten zunächst kafka Server dann nur Sie sollten sich bewegen, um Thema zu erstellen. sieht so aus, als ob kein kafka-server läuft. – binariedMe

kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0

Es heißt, Sie haben 0 Makler zur Verfügung. Stellen Sie also sicher, dass Sie 1 kafka-Broker laufen haben. Sie erhalten diese Ausnahme, wenn Sie number of brokers running < replication-factor haben.

Quelle

2016-05-05 10:55:14 avr

Beim Einrichten von kafka (Einzelmaschine mit mehreren Brokern) beachten Sie, Jede server.properties-Datei in $ kafka_home/config, die mit unterschiedlicher Broker-ID und Portnummer konfiguriert ist, fungiert als einzelner Broker. Wenn Sie zwei Dateien server.properties, z. B. server1.properties und server2.properties im Ordner config mit unterschiedlichen Broker-ID-Werten und Portnummern haben, haben Sie zwei Broker. Und der Replikationsfaktor Ihrer Themen sollte immer kleiner oder gleich der Anzahl Ihrer Broker sein.

Wenn Sie Ihren Fehler betrachten, kann ich sagen, dass kein Kafka-Broker konfiguriert ist. Überprüfen Sie die Datei server.properties einmal. Oder fügen Sie es in die Frage ein, damit ich hineinsehen kann.

Quelle

2017-01-18 07:10:09

Thema erstellen Apache Kafka

Antwort

Verwandte Themen