Après Linux redémarrer, Kafka lancer “aucun courtage trouvé lors de la tentative de rééquilibrer”

J'ai suivi un excellente étape par étape tutoriel pour l'installation de Kafka sur Linux. Tout fonctionnait bien pour moi jusqu'à ce que j'ai redémarré Linux. Après le redémarrage, j'obtiens l'erreur suivante quand j'ai essayer de consommer une file d'attente avec kafka-console-consumer.sh.

$ ~/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic TutorialTopic --from-beginning

[2016-02-04 03:16:54,944] WARN [console-consommation-6966_bob-kafka-tempête-1454577414492-8728ae43], pas de courtiers trouvé lors de la tentative de rééquilibrer. (kafka.à la consommation.ZookeeperConsumerConnector)

Avant j'ai couru le kafka-console-consumer.sh script, je l'ai fait envoyer des données à la Kafka file d'attente à l'aide de la kafka-console-producer.sh script. Ces étapes ont fonctionné sans problème avant de redémarrer Linux.

Je peux corriger l'erreur en démarrant Kafka; mais, je préfère que Kafka démarrer automatiquement.

Ce qui peut provoquer Kafka pour ne pas démarrer correctement après le redémarrage?

OriginalL'auteur Bob Cardenas | 2016-02-04

  1. 1

    Donc j'ai eu un problème similaire dans notre hortonworks a cluster plus tôt aujourd'hui. Il semble que la gardienne n'était pas démarrer correctement. J'ai d'abord essayé kakfa-console-producteur et a obtenu l'exception ci-dessous:

    kafka-console-producer.sh --broker-list=localhost:9093 --topic=some_topic < /tmp/sometextfile.txt```

kafka.common.KafkaException: fetching topic metadata for topics```

    La solution pour moi a été de redémarrer le serveur qui avait cessé de répondre. le vôtre peut être différent, mais jouer avec la console de producteur et de voir ce que les erreurs de votre arriver.

    OriginalL'auteur ben jarman

  2. 1

    Je possède ce même problème aujourd'hui lors de l'exécution d'un consommateur:

    WARN [console-consumer-74006_my-machine.com-1519117041191-ea485191], no brokers found when trying to rebalance. (kafka.consumer.ZookeeperConsumerConnector)

    Il s'est avéré être un disque plein de problème sur la machine. Une fois que l'espace a été libéré, le problème a été résolu.

    OriginalL'auteur jf2010

  3. 0

    La suppression de tout en matière de zookeeper et kafka de le dossier /tmp.. a fonctionné pour moi. Mais mon système n'est pas la production.. donc pour les autres personnes de procéder avec prudence.

    OriginalL'auteur Nate Uni

  4. 0

    Par défaut kafka stocke toutes les informations dans le /tmp dossier. Le dossier tmp est supprimé chaque fois que vous redémarrez. Vous pouvez modifier l'emplacement de ces fichiers par la modification dans le fichier de propriétés config/server.properties la propriété log.dirs.

    OriginalL'auteur Nautilus

  5. 0

    Pour moi，quand commencer un consommateur à extraire le message de courtier en cluster. Mais le Kafka serveur a été fermé.
    Donc, retour le message "pas de courtiers trouvé lors de la tentative de rééquilibrer".
    Lorsque je redémarre l'kafka serveur, l'erreur a disparu.

    OriginalL'auteur lin0Xu

  6. 0

    Pour le producteur consommateur de travail, vous devez commencer à un courtier. Le courtier est ce que les intermédiaires de la transmission de message du producteur au consommateur.

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

    Le courtier s'exécute sur 9092 port par défaut

    OriginalL'auteur Sudip Bhandari