创建使用者后未建立kafka zookeper会话

epfja78i 于 2021-06-07 发布在 Kafka

关注(0)|答案(2)|浏览(270)

这是我第一次使用Kafka。我遵循了这个教程。启动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

我使用的是windows10。
Kafka2.11-2.1.0
Zookeeper-3.4.12

apache-kafka kafka-consumer-api

来源：https://stackoverflow.com/questions/54035885/kafka-zookeper-session-not-established-after-creating-consumer

2条答案

按热度按时间

5kgi1eie1#

@伊萨扬
我试过类似的教程，你张贴在你的部分https://dzone.com/articles/running-apache-kafka-on-windows-os，在那个博客里有一个bug-。
我试着把zookeeper改成本地主机9092的引导服务器，这对我很有用。
试试这个，它应该可以在windows下工作。
c:\dev\kafka\u 2.12-2.2.1\kafka\u 2.12-2.2.1\bin\windows>kafka-console-consumer.bat—引导服务器localhost:9092 --topic 测试--从头开始

赞(0）回复(0）举报 2021-06-07

x0fgdtte2#

我同意了