Мой кластер брокера Kafka на виртуальной машине не может получить запись от производителя-консоли-kafka - PullRequest
Новая
       4

Мой кластер брокера Kafka на виртуальной машине не может получить запись от производителя-консоли-kafka

0 голосов
/ 14 июля 2020

Я столкнулся с проблемой, что производитель моей консоли не может получить доступ к kafka-broker на vm (azure). в чем проблема?

Это моя конфигурация ВМ

Конфигурация ВМ

Это мое сообщение об ошибке из консоли kafka 


    [2020-07-14 14:51:17,377] WARN [Producer clientId=console-producer] Error connecting to node <em>data3.kafka.com:6667</em> (id: 1004 rack: null) (org.apache.kafka.clients.NetworkClient)
    java.io.IOException: Can't resolve address: <em>data3.kafka.com:6667</em>
            at org.apache.kafka.common.network.Selector.doConnect(Selector.java:235)
            at org.apache.kafka.common.network.Selector.connect(Selector.java:214)
            at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:864)
            at org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:64)
            at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1035)
            at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:920)
            at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:508)
            at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:239)
            at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:163)
            at java.lang.Thread.run(Unknown Source)
    Caused by: java.nio.channels.UnresolvedAddressException
            at sun.nio.ch.Net.checkAddress(Unknown Source)
            at sun.nio.ch.SocketChannelImpl.connect(Unknown Source)
            at org.apache.kafka.common.network.Selector.doConnect(Selector.java:233)
            ... 9 more
    [2020-07-14 14:51:17,691] WARN [Producer clientId=console-producer] Error connecting to node <em>data2.kafka.com:6667</em> (id: 1003 rack: null) (org.apache.kafka.clients.NetworkClient)
    java.io.IOException: Can't resolve address: <em>data2.kafka.com:6667</em>
            at org.apache.kafka.common.network.Selector.doConnect(Selector.java:235)
            at org.apache.kafka.common.network.Selector.connect(Selector.java:214)
            at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:864)
            at org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:64)
            at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1035)
            at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:920)
            at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:508)
            at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:239)
            at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:163)
            at java.lang.Thread.run(Unknown Source)
    Caused by: java.nio.channels.UnresolvedAddressException
            at sun.nio.ch.Net.checkAddress(Unknown Source)
            at sun.nio.ch.SocketChannelImpl.connect(Unknown Source)
            at org.apache.kafka.common.network.Selector.doConnect(Selector.java:233)
            ... 9 more
    [2020-07-14 14:51:17,844] WARN [Producer clientId=console-producer] Error connecting to node <em>data1.kafka.com:6667</em> (id: 1002 rack: null) (org.apache.kafka.clients.NetworkClient)
    java.io.IOException: Can't resolve address: <em>data1.kafka.com:6667</em>
            at org.apache.kafka.common.network.Selector.doConnect(Selector.java:235)
            at org.apache.kafka.common.network.Selector.connect(Selector.java:214)
            at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:864)
            at org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:64)
            at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1035)
            at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:920)
            at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:508)
            at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:239)
            at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:163)
            at java.lang.Thread.run(Unknown Source)
    Caused by: java.nio.channels.UnresolvedAddressException
            at sun.nio.ch.Net.checkAddress(Unknown Source)

1 Ответ

0 голосов
/ 24 июля 2020

Мне только что добавили 3 строки в мой файл hosts:

22.33.44.55 data1.kafka.com 22.33.44.55 data2.kafka.com 22.33.44.55 data3.kafka.com

Это просто работает.

...