Fehler FEHLER beim senden der Nachricht zum Thema

Während der Herstellung Botschaft in kafka, ich erhalte die folgende Fehlermeldung :

$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic nil_PF1_P1
hi
hello

[2016-07-19 17:06:34,542] ERROR Error when sending message to topic nil_PF1_P1 with key: null, value: 2 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
[2016-07-19 17:07:34,544] ERROR Error when sending message to topic nil_PF1_P1 with key: null, value: 5 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.


$ bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic nil_PF1_P1
Topic:nil_PF1_P1    PartitionCount:1    ReplicationFactor:1 Configs:
Topic: nil_PF1_P1   Partition: 0    Leader: 2   Replicas: 2 Isr: 2

Irgendeine Idee dazu??

Kannst du die Ergebnisse des folgenden Befehls bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic nil_PF1_P1
Umgebucht nach edition!!
Es scheint, alles ist gut, zk Ende. Es scheint, dass es problem mit Kafka broker bind-Adresse und port! Können Sie überprüfen, ob Ihr kafka ist erreichbar unter localhost:9092?
btw, welche version von Kafka benutzt du? wenn es 0.9 oder später werden Sie es konfiguriert mit ssl? wenn dann müssen Sie die ssl-info beim produzieren und konsumieren!
ja, es ist 0.10.0.0 . was ist ssl ? Können Sie kurz erklären. Ein link auch tun!! Vielen Dank im Voraus!!

InformationsquelleAutor Nilotpal | 2016-07-19

  1. 10

    Anstelle der änderung der server.Eigenschaften umfassen die 0.0.0.0 in den code selbst. Dies löste das problem für mich.

    Statt

        /usr/bin/kafka-console-producer --broker-list Hostname:9092 --topic MyFirstTopic1

    Verwenden:

        /usr/bin/kafka-console-producer --broker-list 0.0.0.0:9092 --topic MyFirstTopic1

    InformationsquelleAutor V.Bravo

  2. 9

    Es kann sein, weil einige Parameter von kafka server.Eigenschaften-Datei.
    Folgende Lösung funktionierte für mich. Weitere Informationen finden Sie hier

    1) beenden Sie die kakfka server.

    $ cd $KAFKA_HOME/bin

    $ ./kafka-server-stop.sh

    2) Geändert

    Zuhörer=PLAINTEXT://hostname:9092

    zu

    Zuhörer=PLAINTEXT://0.0.0.0:9092

    vom

    $KAFKA_HOME/config/server.Eigenschaften`

    Datei.

    3) starten Sie kafka server.

    $KAFKA_HOME/bin/kafka-server-start.sh /kafka/config/server.Eigenschaften

    InformationsquelleAutor Yogesh Jilhawar

  3. 8

    Wenn Sie mit hortonworks cluster, überprüfen Sie den listening-port in ambari.

    In meinem Fall 9092 war nicht mein port. Ich ging zu ambari und fand die - listening-port eingestellt war, 6667
    es funktionierte für mich. 🙂

    InformationsquelleAutor pooja patil

  4. 8

    Ich weiß, das ist alt, aber das kann für jemand anderes arbeiten, der Umgang mit ihm:
    Ich habe 2 Dinge geändert:

    1. ändern Sie die "bootstrap.Server" - Eigenschaft oder die --Makler-Liste option 0.0.0.0:9092

    2. ändern (kommentieren und Bearbeiten-in meinem Fall der server.Eigenschaften 2 Eigenschaften

    • Zuhörer = PLAINTEXT://Ihre.host.name:9092 zu Zuhörer=PLAINTEXT://:9092
    • beworben.Listener=PLAINTEXT://Ihre.host.name:9092 zu beworben.Listener=PLAINTEXT://localhost:9092
    0.0.0.0 war die wichtigste Lösung, weil localhost ist 127.0.0.1 also wie würde es funktionieren?
    Nein, dass ist nicht, wo die Lösung liegt, es nur, dass Sie brauchen, um zu konfigurieren Sie den Endpunkt des service ordnungsgemäß auf dem server durch ändern der Eigenschaften, die ich erwähnt da es sonst geben Sie die Standard-lokale ipv4-Adresse zurückgegeben, die von java.net.InetAddress.getCanonicalHostName() also nur um sicherzustellen, dass Sie eine lokale ipv4-Adresse, die Sie verwenden können, 0.0.0.0, aber Sie können auch verwenden, 127.0.0.1 nach dem konfigurieren einwandfrei
    sagen Sie 0.0.0. arbeitet aufgrund einiger anderer Problem?

    InformationsquelleAutor Danny Mor

  5. 3

    Bekomme ich den gleichen Fehler heute mit confluent_kafka 0.9.2 (0x90200) und librdkafka 0.9.2 (0x90401). In meinem Fall habe ich angegeben, den falschen broker-port in tutorialpoints Beispiel:

    $ kafka-console-producer.sh --broker-list localhost:9092 --topic tutorialpoint-basic-ops-01

    obwohl mein broker war gestartet auf port 9094:

    $ cat server-02.properties 
broker.id=2
port=9094
log.dirs=/tmp/kafka-example-logs-02
zookeeper.connect=localhost:2181

    Obwohl die 9092 port nicht geöffnet war (netstat -tunap), es dauerte 60s für kafka-console-producer.sh einen Fehler auslösen. Sieht aus wie dieses tool benötigt ein Update zu:

    • schneller scheitern
    • mit mehr explizite Fehlermeldung.

    InformationsquelleAutor m-ric

  6. 3

    Ich vor ähnlichen problem, wo ich war in der Lage zu produzieren und zu konsumieren auf localhost aber nicht von verschiedenen Rechnern über Netzwerk. Basierend paar Antworten, die ich bekam die Ahnung, dass im Grunde müssen wir aussetzen advertised.listener um Produzent und Verbraucher, jedoch gibt 0.0.0.0, war auch nicht arbeiten. So gab genaue IP gegen advertised.listeners

    advertised.listeners=PLAINTEXT://HOST.IP:9092

    Und ich verließ listener=PLAINTEXT://:9092 wie es ist.

    Also mit diesem der Funke aussetzt beworben ip und port zu Produzenten und Konsumenten

    Sie haben Recht, Sie müssen setzen advertised.listeners=PLAINTEXT://HOST.IP:9092 wenn Sie wollen, zu produzieren oder zu konsumieren, die aus verschiedenen Maschinen

    InformationsquelleAutor Arun Y

  7. 2

    Hatte dieses Problem:
    Mit Hortonworks HDP 2.5.
    Kerberisation aktiviert

    Fest, indem Sie die richtigen Sicherheits-Protokoll und ports.
    Befehlen Beispiel:

    ./kafka-console-producer.sh --broker-list sand01.intranet:6667, san02.intranet:6667, san03.intranet:6667--topic test--security-protocol PLAINTEXTSASL


./kafka-console-consumer.sh --zookeeper sand01:2181 --topic test--from-beginning --security-protocol PLAINTEXTSASL

    InformationsquelleAutor Prasad Deshpande

  8. 2

    In meinem Fall, ich bin mit Kafka Andockfenster mit Openshift. Ich war immer das gleiche problem. Hab es behoben, wenn ich an die Umgebungsvariable KAFKA_LISTENERS mit einem Wert von PLAINTEXT://:9092. Dies wird schließlich fügen Sie einen Eintrag erstellen listeners=PLAINTEXT://:9092 unter server.Eigenschaften.

    Den Hörer nicht haben, um einen Hostnamen.

    InformationsquelleAutor Kannan Ramamoorthy

  9. 2

    Stand ich vor der oben genannten exception-stacktrace. Ich untersuchte und fand die Ursache.Ich stieß darauf, als ich festgestellt Kafka-cluster mit zwei Knoten.Mit den folgenden Einstellungen in server.Eigenschaften.Hier bin ich mit fehlerhaften server.Eigenschaften von kafka Knoten 1 und 2 als broker1.Eigenschaften und broker2.Eigenschaften

    broker1.- Eigenschaften-Einstellungen

        listeners=PLAINTEXT://A.B.C.D:9092
    zookeeper.connect=A.B.C.D:2181,E.F.G.H:2181

    broker2.- Eigenschaften-Einstellungen

        listeners=PLAINTEXT://E.F.G.H:9092
    zookeeper.connect=A.B.C.D:2181,E.F.G.H:2181

    War ich versucht zu starten, ein Produzent von Knoten 1 oder Knoten 2 mit dem folgenden Befehl:
    ./bin/kafka-console-producer.sh --Makler-Liste localhost:9092 --Thema OUR_TOPIC
    und ich war immer die oben genannten timeout-exception-stacktrace-obwohl Kafka läuft in die Maschine.

    Obwohl Produzent ist der Ausgangspunkt entweder von den Leader-Knoten oder von einem follower ich war immer die gleiche.

    Während der Verwendung unter Befehl von einem broker ich war in der Lage, producer der Nachricht.

       ./bin/kafka-console-producer.sh --broker-list A.B.C.D:9092 --topic OUR_TOPIC
    or
   ./bin/kafka-console-producer.sh --broker-list E.F.G.H:9092 --topic OUR_TOPIC
   or
   ./bin/kafka-console-producer.sh --broker-list A.B.C.D:9092,E.F.G.H:9092 --topic OUR_TOPIC

    Also die Ursache ist, dass Kafka broker intern mit Listener=PLAINTEXT://E. F. G. H:9092 Eigenschaft starrend Produzent.Diese Eigenschaft muss match zu starten, eine kafka-broker aus jedem der Knoten beim Start eines Produzenten.Konvertieren Sie diese Eigenschaft, um die Zuhörer=PLAINTEXT://localhost:9092 für unsere ersten Befehl.

    InformationsquelleAutor Afsar

  10. 2

    Einem anderen Szenario hier. Keine Ahnung, was passiert war, bis ich eine kafka-log mit der folgenden Meldung:

    Caused by: java.lang.IllegalArgumentException: Invalid version for API key 3: 2

    Offenbar der Produzent war mit einer neueren kafka-client (java), als die kafka-server und die API verwendet wurde, war ungültig (client mit 1.1 und server 10.0). Auf der Client/Produzent, den ich bekam:

    Error producing to topic Failed to update metadata after 60000 ms.

    InformationsquelleAutor Lemmerich

  11. 2

    Apache Kafka v2.11-1.1.0

    Start zookeeper server:

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

    Start kafka server:

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

    Erstellen eines " topic name "my_topic":

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

    Starten Sie die Hersteller:

    $ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my_topic

    Starten Sie den Verbraucher:

    $ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic --from-beginning

    InformationsquelleAutor Steven

Schreibe einen Kommentar