Соединение с узлом -1 не может быть установлено. Брокер может быть недоступен. (Org.apache.kafka.clients.NetworkClient) - PullRequest
Новая
       39

Соединение с узлом -1 не может быть установлено. Брокер может быть недоступен. (Org.apache.kafka.clients.NetworkClient)

1 голос
/ 16 мая 2019

Я установил Kafka и провожу базовое тестирование.Я могу создавать темы, используя сценарии, которые находятся в папке Kafka-broker / bin.

Но когда я пытаюсь выдавать сообщение ниже WARNing каждый раз, когда я запускаю это.И никакое сообщение не генерируется.Пожалуйста, совет. 

[root@node2 bin]# ./kafka-console-producer.sh --broker-list localhost:9092 --topic test_master
>testmsg1
    [2019-05-15 06:25:19,092] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
    [2019-05-15 06:25:19,197] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
    [2019-05-15 06:25:19,349] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
    [2019-05-15 06:25:19,562] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
    [2019-05-15 06:25:20,017] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
    [2019-05-15 06:25:20,876] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
    [2019-05-15 06:25:21,987] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
    [2019-05-15 06:25:22,957] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
    [2019-05-15 06:25:23,818] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
    ^Corg.apache.kafka.common.KafkaException: Producer closed while send in progress
            at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:826)
            at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:803)
            at kafka.tools.ConsoleProducer$.send(ConsoleProducer.scala:75)
            at kafka.tools.ConsoleProducer$.main(ConsoleProducer.scala:57)
            at kafka.tools.ConsoleProducer.main(ConsoleProducer.scala)
    Caused by: org.apache.kafka.common.KafkaException: Requested metadata update after close
            at org.apache.kafka.clients.Metadata.awaitUpdate(Metadata.java:188)
            at org.apache.kafka.clients.producer.KafkaProducer.waitOnMetadata(KafkaProducer.java:938)
            at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:823)
            ... 4 more

1 Ответ

1 голос
/ 16 мая 2019

Откройте Server.xml каждого брокера вашего кластера и внесите следующие изменения

Измените listeners=PLAINTEXT://:9092 на listeners=PLAINTEXT://<our ip address>:9092

...