ERREUR Erreur lors de l'envoi d'un message à un sujet

Tout en produisant un message dans kafka, j'obtiens l'erreur suivante :

$ 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

Aucune idée sur ça???

source d'informationauteur Nilotpal | 2016-07-19

  1. 9

    Si vous exécutez hortonworks a cluster, vérifiez le port d'écoute dans ambari.

    Dans mon cas 9092 n'était pas mon port. Je suis allé à ambari et trouvé le port d'écoute a été mis à 6667
    il a travaillé pour moi. 🙂

  2. 8

    Au lieu de changer le serveur.propriétés incluent la 0.0.0.0 dans le code lui-même. Cela a résolu le problème pour moi.

    Au lieu de

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

    Utilisation:

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

    Il peut être à cause de certains paramètres de kafka serveur.fichier de propriétés.
    Suivant la solution a fonctionné pour moi. Vous pouvez trouver plus d'informations ici

    1) arrêter le kakfka serveur.

    $ cd $KAFKA_HOME/bin

    $ ./kafka-server-stop.sh

    2) Modifié

    auditeurs=PLAINTEXT://hostname:9092

    à

    auditeurs=PLAINTEXT://0.0.0.0:9092

    de

    $KAFKA_HOME/config/serveur.propriétés`

    fichier.

    3) redémarrez kafka serveur.

    $KAFKA_HOME/bin/kafka-server-start.sh /kafka/config/serveur.propriétés

  4. 5

    Je sais que c'est vieux, mais cela peut fonctionner pour quelqu'un d'autre qui le traiter:
    J'ai changé 2 choses:

    1. modifier la "bootstrap.les serveurs" de la propriété ou de la --courtier-liste option pour 0.0.0.0:9092

    2. changement (commentaires et de modifier dans mon cas) le serveur.propriétés dans les 2 propriétés

    • auditeurs = PLAINTEXT://votre.de l'hôte.nom:9092 à auditeurs=PLAINTEXT://:9092
    • annoncés.les auditeurs=PLAINTEXT://votre.de l'hôte.nom:9092 à annoncés.les auditeurs=PLAINTEXT://localhost:9092
  5. 2

    Je reçois la même erreur aujourd'hui avec confluent_kafka 0.9.2 (0x90200) et librdkafka 0.9.2 (0x90401). Dans mon cas, j'ai précisé que le mauvais courtier port tutorialpoints exemple:

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

    bien que mon courtier a été démarré sur le port 9094:

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

    Bien que le 9092 port n'a pas été ouvert (netstat -tunap), il a fallu des années 60 pour kafka-console-producer.sh pour générer une erreur. Ressemble cet outil a besoin d'un correctif:

    • échouent plus vite
    • avec un message d'erreur explicite.
  6. 2

    Eu ce problème:
    À l'aide de hortonworks a HDP 2.5.
    Kerberisation activé

    Fixe en fournissant le bon protocole de sécurité et les ports.
    Exemples de commandes:

    ./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
  7. 2

    Dans mon cas, je suis à l'aide de Kafka docker avec Openshift. J'ai fait le même problème. C'suis fixé quand j'ai passé la variable d'environnement KAFKA_LISTENERS avec une valeur de PLAINTEXT://:9092. Ce sera éventuellement ajouter de créer une entrée listeners=PLAINTEXT://:9092 sous serveur.propriétés.

    Les auditeurs ne pas avoir un nom d'hôte.

  8. 2

    J'ai fait face à l'exception ci-dessus stacktrace. J'ai enquêté et trouvé la cause.J'ai fait face à ça quand j'ai créé Kafka cluster à deux nœuds.Avec les paramètres suivants dans le serveur.les propriétés.Ici, je suis dénotant serveur.propriétés de kafka nœud 1 et 2 comme broker1.propriétés et broker2.propriétés

    broker1.les paramètres de propriétés de

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

    broker2.les paramètres de propriétés de

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

    Je tente de démarrer un producteur de node1 ou de node2 à l'aide de la commande suivante:
    ./bin/kafka-console-producer.sh --courtier-liste localhost:9092 --sujet OUR_TOPIC
    et je commençais à l'exception délai ci-dessus stacktrace bien que Kafka est en cours d'exécution dans les deux machine.

    Bien que le réalisateur est à partir de nœud " Leader ou un suiveur j'étais toujours le même.

    Tout en utilisant la commande ci-dessous à partir de n'importe quel courtier, j'ai été en mesure d'obtenir le producteur du message.

       ./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

    Si la cause est que Kafka courtier en interne à l'aide d'écouteurs=PLAINTEXT://E. F. G. H:9092 propriété, tout en fixant un producteur.Cette propriété doit correspondre à démarrer un kafka courtier à partir du nœud lors du lancement d'un producteur.La conversion de cette propriété pour les auditeurs=PLAINTEXT://localhost:9092 de travail pour notre première commande.

  9. 2

    J'ai fait face à ce genre de problème, où j'ai été en mesure de produire et de consommer sur localhost mais pas à partir de différents ordinateurs sur le réseau. Basée quelques réponses que j'ai eu l'idée que l'essentiel, nous devons dénoncer la publicité.auditeur pour le producteur et le consommateur, toutefois donner de 0.0.0.0 était pas non plus de travail. Donc a donné IP exacte contre advertised.listeners

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

    Et j'ai laissé listener=PLAINTEXT://:9092 comme il est.

    De sorte à ce que l'étincelle expose annoncé ip et le port pour les producteurs et les consommateurs

  10. 2

    Un autre scénario ici. Aucune idée sur ce qui se passait jusqu'à ce que je trouve un kafka, journal, avec le message suivant:

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

    Apparemment, le producteur a l'aide d'une nouvelle de kafka-client (java) que le kafka du serveur et de l'API utilisée n'était pas valide (client à l'aide de 1,1 et serveur sur 10.0). Sur le Client/Producteur, j'ai eu l':

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