Не удалось установить соединение kafka с брокером kafka - PullRequest
0 голосов
/ 05 августа 2020

Я использую ma c и устанавливаю zookeeper и kafka через

brew install confluent-platform

Используя следующие команды,

zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties
kafka-server-start /usr/local/etc/kafka/server.properties
connect-distributed /usr/local/etc/kafka/connect-distributed.properties

, на коннекторе отображаются следующие сообщения, например

[2020-08-05 09:53:40,222] WARN [Producer clientId=inventory-connector2-dbhistory] Connection to node -1 (kafka/223.82.248.117:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:756)
[2020-08-05 09:53:40,230] WARN [Producer clientId=inventory-connector2-dbhistory] Bootstrap broker kafka:9092 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient:1024)
[2020-08-05 09:53:40,427] WARN [Producer clientId=inventory-connector-dbhistory] Connection to node -1 (kafka/223.82.248.117:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:756)

Я запустил брокера kafka на локальном хосте, но, как видно из сообщения, адрес брокера 223.82.248.117:9092.

как мне это исправить?

1 Ответ

0 голосов
/ 05 августа 2020

Вам нужно будет установить advertised.listeners в server.properties как localhost:9092

Затем bootstrap.servers в connect-*.properties, чтобы указать и на

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...