Fehler beim erstellen des Kafka-Themen - Replikation Faktor größer als der verfügbare Broker

Ich versuche zu erstellen Themen bei Kafka, indem Sie die Anleitung auf Apache Kafka-website über die Kommandozeile.
Während der Ausführung des Befehls:

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

Bekomme ich die Fehlermeldung wie folgt:

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)

[2015-10-13 14:25:38,607] INFO Processed session termination for sessionid: 0x15
06056566d0004 (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-10-13 14:25:38,608] INFO Closed socket connection for client /127.0.0.1:33
391 which had sessionid 0x1506056566d0004 (org.apache.zookeeper.server.NIOServer
Cnxn)

Wie kann ich das Problem beheben? Jede gute Dokumentation mit diesem Einstieg?
Danke!!

Es sagt ganz klar 0 broker verfügbar ist . Starten Sie einen broker
Ich hatte das gleiche problem und verpasste den Teil, wo Sie hatte zu Beginn der kafka-server, nachdem der Tierpfleger.

InformationsquelleAutor Nicole | 2015-10-13

  1. 14

    Scheint dein server nicht gestartet wird , überprüfen Sie die Protokolle für die Ausgabe

    Kill process

    sudo fuser -k 2181/tcp

    laufen Tierpfleger 

    bin/zookeeper-server-start.sh config/zookeeper.properties

    Laufen Kafka

    bin/kafka-server-start.sh config/server.properties  '

    InformationsquelleAutor vaquar khan

  2. 4

    Er sagt ganz klar 0 broker verfügbar ist . Starten Sie einen broker 

    bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

    auf der Basis von Apache Kafka tutorial dann versuchen

    InformationsquelleAutor vasa.v03

  3. 4

    Wenn ich du wäre würde ich versuchen, diesen code:

    bin/kafka-topics.sh --erstellen --Tierpfleger localhost:2181/kafka
    --Replikations-Faktor 1 --partitions 1 --Thema-test

    Wenn Sie mit einem cluster, in denen Tierpfleger verteilt werden 3 Knoten sollten Sie substitue localhost:2181/kafka für direccion1:2181,direction2:2181,direction3:2181/kafka

    InformationsquelleAutor Anxo P

  4. 2

    Habe ich das gleiche problem hatte.Ich das problem lösen.Ich glaube, der Grund für dieses ist, weil es keine hintergrund-start-up.
    so,wir neet start-up-hintergrund

    bin/kafka-server-start.sh config/server.properties &
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test &

    InformationsquelleAutor chunbo

  5. 1

    Ihre Tierpfleger ist nicht in der Lage, um zu sehen, alle Kafka-Broker.Versuchen Sie sich in Ihrem Zookeepr Konsole : bin/zkCli.sh -server localhost:2181
    Führen Sie [zk: localhost:2181(CONNECTED) 2] ls /brokers/ids auf der Konsole. Es muss nicht zeigen, bis jeder Broker. Sie müssen neu starten, alle Ihre Kafka-Broker, und überprüfen Sie für die kafka-Prozess-log. Manchmal, selbst wenn der Prozess zeigt, wie ausgeführt (ps -ef | grep kafka), kann es nicht wirklich vollständig gestartet werden, weil die Tierpfleger nicht in der Lage ist, es zu sehen. Ich hatte das gleiche Problem mit Apache Kafka Verteilung 0.11.0.

    InformationsquelleAutor Binita Bharati

  6. 1

    Ich hatte das gleiche problem, aber endlich habe ich versucht die folgenden Schritte, die für mich gearbeitet:

    1)Erstellen der chroot-Umgebung, in der Tierpfleger mit den folgenden Befehlen:

    zkCli.sh -server localhost:2181

    erstellen /kafka1 []

    2)Für die kafka-Broker config ändern Tierpfleger.verbinden und fügen chroot-Pfad :
    Für zB.

    Server ein.Eigenschaften :

    Tierpfleger.connect=localhost:2181/kafka1

    3)Starten Tierpfleger

    4)Starten Kafka Server

    5) Erstellen Sie ein Thema wie folgt:
    bin/kafka-topic.sh --create-Tierpfleger localhost:2181/kafka1 --Replikations-Faktor 1 --partitions 1 --Thema Daten

    6)Bestätigen Sie das erstellte Thema:
    bin/kafka-topics.sh --list --Tierpfleger localhost:2181/kafka1

    Folgte ich unten als Referenz:
    https://community.hortonworks.com/questions/102132/run-multiple-broker-versions-in-the-same-cluster.html

    InformationsquelleAutor Amit Kumar

  7. 0

    Das gleiche Szenario Stand ich nach dem löschen das einzige Thema, das ich erstellt hatte.

    Den Weg, es zu lösen wurde Kafka und Tierpfleger herunter, aktualisiert Kafka-Einstellungen (server.Eigenschaften-Datei), wo ich die folgende Einstellung hinzufügen,

    delete.topic.enable=true

    Datei gespeichert haben, drehen Tierpfleger und Kafka bis und alles laufen wie gewohnt.

    InformationsquelleAutor nano

  8. 0

    stellen Sie sicher, dass die kafka-server ist korrekt gestartet. Wenn Sie mit -dameon parameter starten kafka-server als daemon. Versuchen, Sie zu entfernen und sehen, ob es irgendwelche Fehler während der Inbetriebnahme.

    Das Problem, das ich gestoßen bin, stellte sich heraus, dass ein Datei-Zugriff-Problem, wo der Benutzer führt kafka keinen Zugriff auf das log-Verzeichnis habe ich konfiguriert. Nachdem ich gewährt den Zugang, es funktioniert einfach!

    InformationsquelleAutor Mingliang

  9. 0

    Versuchen Sie, in Ihrem serverwith:

    delete.topic.enable=true

    InformationsquelleAutor Enrique Zetina

  10. -1

    Habe ich das gleiche problem hatte. Folgen Sie diesen Teil der Anleitung:
    http://kafka.apache.org/documentation.html#quickstart_multibroker

    Hatte ich nicht erstellt broker. Erstellen von 2 neuen Brokern und Sie das problem lösen wird. Befolgen Sie diese Schritte: 

    cp config/server.properties config/server-1.properties
cp config/server.properties config/server-2.properties

    Sobald Sie erstellen, die Dateien, die Sie haben, um Sie zu konfigurieren mit dieser einige änderungen:

    In "server-1.Eigenschaften":

    broker.id=1
port=9093 
log.dir=/tmp/kafka-logs-1
host.name=localhost

    (Port-Nummer muss die port-Nummer, haben Sie in Ihrem server.Eigenschaften + 1. Ich hatte 9092 so, ich habe das schreiben 9093)

    In "server-2.Eigenschaften":

    broker.id=2
port=9094
log.dir=/tmp/kafka-logs-2
host.name=localhost

    (Port-Nummer muss die nächste server-1. In meinem Fall 9094)

    InformationsquelleAutor pcoello25

Schreibe einen Kommentar