Кафка-консоль потребителя.ОШИБКА Соединение с узлом 0 не может быть установлено. Брокер может быть недоступен - PullRequest
Новая
       2

Кафка-консоль потребителя.ОШИБКА Соединение с узлом 0 не может быть установлено. Брокер может быть недоступен

0 голосов
/ 11 апреля 2019

Я пытаюсь получить сообщение от kafka на моем локальном компьютере (виртуальный рабочий стол Windows 7)

  1. zookeeper и kafka работают на одном локальном компьютере
  2. Создать тему 
kafka-topics --zookeeper 127.0.0.1:2181 --topic first_topic --create -- partitions 3 --replication-factor 1
Created successful
  1. Создать сообщение kafka-console-продюсер --broker-list 127.0.0.1:9092 --topic first_topic нет ошибки, я просто делаю Ctrl + C и заканчиваю производить
  2. Сообщение о потреблении 
kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic first_topic --from-beginning
ERROR : 
WARN [Consumer clientId=consumer-1, groupId=console-consumer-71129] Connection to node 0 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

пожалуйста, помогите!

в настройках server.properties 

broker.id=0
advertised.port=9092
advertised.host.name=127.0.0.1
listeners=PLAINTEXT://127.0.0.1:9092
advertised.listeners=PLAINTEXT://127.0.0.1:9092

1 Ответ

0 голосов
/ 11 апреля 2019
  1. Если вы работаете на локальном компьютере, вам не нужно добавлять эти свойства ниже.

Закомментируйте их. 

advertised.port=9092
advertised.host.name=127.0.0.1
listeners=PLAINTEXT://127.0.0.1:9092
advertised.listeners=PLAINTEXT://127.0.0.1:9092

Добавьте / измените следующие свойства в server.properties, как показано ниже: 

zookeeper.connect=<computer name>:2181

В zookeeper.properties:

Создайте папку скажем в D: / drive и поместите еев zookeeper.properties, как показано ниже

dataDir = D: \\ foldername \\ zookeeper

Вы можете использовать localhost вместо 127.0.0.1 также во всех командах.

Попробуйте это, это может помочь

...