Kafka Windows运行错误：创建消费者报错 consumer zookeeper is not a recognized option

末蓝、 2021-12-20 00:25 346阅读 0赞

出现该错，不用修改任何配置文件，原因为： 当前使用的 创建消费者命令 与 安装的kafka版本不一致，因为kafka在0.9版本之后，使用创建的kafka 消费者命令已经变了。

例如，我安装的是kafka 2.1.1版本， 创建消费者consumer 应该如下：

进入kafka安装目录， 运行命令：

  1. bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testJc --from-beginning

如：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1Mzg3OTQw_size_16_color_FFFFFF_t_70

或者进入到windows目录：

.\kafka-console-consumer.bat —bootstrap-server localhost:9092 —topic testJc

PS ： 创建主题：

进入kafka安装目录， 运行命令：

  1. bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic testJc

如：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1Mzg3OTQw_size_16_color_FFFFFF_t_70 1

或者进入到windows目录下：

kafka-topics.bat —create —zookeeper localhost:2181 —replication-factor 1 —partitions 1 —topic test098

20201106170436258.png

创建生产者 producer：

进入kafka安装目录， 运行命令：

  1. bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic testJc

如：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1Mzg3OTQw_size_16_color_FFFFFF_t_70 2

然后输入需要推送的消息，就可看到监听同一个主题的消费者能成功收到消息：

如：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1Mzg3OTQw_size_16_color_FFFFFF_t_70 3

发表评论

表情：
评论列表 （有 0 条评论，346人围观）

还没有评论，来说两句吧...

相关阅读