时间戳

首页 > 解决方案 > 无法在 Windows 中使用 kafka cmd 创建消费者

apache-kafka - 无法在 Windows 中使用 kafka cmd 创建消费者

问题描述

我有环境问题。我想使用 zookeeper 和 Kafka 集群来解决我的问题。

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

我还更改了 zookeeper 中的 zoo.cfg。

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

和 kafka 中的 server.properties。

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

我看到了所有教程并以完全相同的方式进行操作。并且还使用 kafka open zookeeper。

这是我的命令：

1）打开zookeeper（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 你好

5）创建消费者

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

当我进入第 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 时，我的 zookeeper 有时没有任何响应或向我显示：

 [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

我也谷歌这个，但没有帮助。

我之前在 kfaka 中设置了这个：adverted.host.name = localhost listeners=PLAINTEXT://127.0.0.1:9092

我的主机设置了 127.0.0.1 localhost

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

谢谢你阅读所有。

标签： apache-kafkaapache-zookeeper

解决方案

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

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

再次查看快速入门指南

推荐阅读