无法在 windows 中使用 kafka cmd 创建消费者

Question

我遇到了环境问题。我想用zookeeper和Kafka集群来解决我的问题

我的zookeeper版本是3.4.12，Kafka是2.12-2.1.0

我也把zookeeper里的zoo.cfg改了

dataDir=D:/WEBSOCKET/zookeeper-3.4.12/data

和 server.properties 在 kafka 中。

log.dirs=D:/WEBSOCKET/kafka_2.12-2.1.0/logs

我看了所有的教程，并以完全相同的方式进行操作。还有usgin kafka open zookeeper.

这是我的命令：

1) 打开动物园管理员 (zkServer.cmd)

2) 在卡夫卡中

.\bin\windows\kafka-server-start.bat.\config\server.properties

3) 创建主题

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic hello

4) 创建生产者

.\bin\windows\kafka-console-producer.bat --bootstrap-server localhost:2181 --topic hello

5) 创建消费者

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic hello

当我进入第 5 步时，我总是失败。 zookeeper 会给我很多控制台，比如 :

 WARN  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@383] - Exception causing close of session 0x0: null
 INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Accepted socket connection from /127.0.0.1:55192

和

2019-01-08 17:05:24,822 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1040] - Closed socket connection for client /127.0.0.1:50874 (no session established for client)
2019-01-08 17:05:25,783 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Accepted socket connection from /127.0.0.1:56089

我不知道如何修复它。我google两天...

当我在第 2 步打开我的 Kafka 时，我的动物园管理员有时没有任何响应或显示如下：

 [ProcessThread(sid:0 cport:2181)::PrepRequestProcessor@596] - Got user-level KeeperException when processing sessionid:0x1000058f8960000 type:multi cxid:0x36 zxid:0x69 txntype:-1 reqpath:n/a aborting remaining multi ops. Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election

我也google这个，但没有帮助。

我之前在kfaka里这样设置的： advertised.host.name = 本地主机 listeners=PLAINTEXT://127.0.0.1:9092

我的主机已设置 127.0.0.1 本地主机

请帮我创建本地服务器我想编码我的项目..

感谢您阅读全部。

Answer 1

生产者和消费者需要使用9092端口（Kafka）

您正在查看 Zookeeper 日志和错误，因为您正在尝试使用 bootstrap-server 或 broker-list 和端口 2181 (Zookeeper)

再次检查the quickstart guide

无法在 windows 中使用 kafka cmd 创建消费者

Can not creat consumer with kafka cmd in windows

apache-kafka

apache-zookeeper