Сессия Kafka zookeper не установлена ​​после создания потребителя - PullRequest
Новая
       12

Сессия Kafka zookeper не установлена ​​после создания потребителя

0 голосов
/ 04 января 2019

Я впервые использую Кафку.Я следовал этому учебнику.После запуска Zookeper я запустил сервер kafka.Затем была создана тема, а затем начался потребитель для этой темы.Это когда в журналах Zookeper появляется сообщение

Исключение, вызывающее закрытие сеанса 0x0: null 

2019-01-04 14:11:58,160 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1040] - Closed socket connection for client /127.0.0.1:50480 (no session established for client)
2019-01-04 14:11:59,073 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Accepted socket connection from /127.0.0.1:50481
2019-01-04 14:11:59,074 [myid:] - WARN  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@383] - Exception causing close of session 0x0: null
2019-01-04 14:11:59,078 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1040] - Closed socket connection for client /127.0.0.1:50481 (no session established for client)
2019-01-04 14:11:59,994 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Accepted socket connection from /127.0.0.1:50482
2019-01-04 14:11:59,995 [myid:] - WARN  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@383] - Exception causing close of session 0x0: null

Я использую Windows 10.

kafka_2.11-2.1.0

zookeeper-3.4.12

1 Ответ

0 голосов
/ 15 июня 2019

@ itssajan

Я пробовал аналогичное руководство, как вы разместили в своем разделе https://dzone.com/articles/running-apache-kafka-on-windows-os,, в этом блоге есть ошибка.

Я попытался изменить zookeeper на bootstrap-сервер с localhost 9092, и у меня это сработало.

попробуйте, это должно работать в Windows.

C: \ dev \kafka_2.12-2.2.1 \ kafka_2.12-2.2.1 \ bin \ windows> kafka-console-consumer.bat --bootstrap-server localhost: 9092 --топический тест --от начала

...