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

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

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


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


进入kafka安装目录, 运行命令:


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


如:


image.png


或者进入到windows目录:


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

PS : 创建主题:


进入kafka安装目录, 运行命令:


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

如:


 image.png


或者进入到windows目录下:


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


image.png


创建生产者 producer:


进入kafka安装目录, 运行命令:


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


如:


image.png


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


如:


image.png

相关文章
|
消息中间件 Kafka
使用kafka consumer加载数据加载异常并且报source table and destination table are not same错误解决办法
使用kafka consumer加载数据加载异常并且报source table and destination table are not same错误解决办法
|
消息中间件 存储 分布式计算
大数据-53 Kafka 基本架构核心概念 Producer Consumer Broker Topic Partition Offset 基础概念了解
大数据-53 Kafka 基本架构核心概念 Producer Consumer Broker Topic Partition Offset 基础概念了解
471 4
|
消息中间件 Java Kafka
windows服务器重装系统之后,Kafka服务如何恢复?
windows服务器重装系统之后,Kafka服务如何恢复?
320 8
|
存储 Shell 开发工具
8-8|windows上Git报错
8-8|windows上Git报错
|
消息中间件 安全 大数据
Kafka多线程Consumer是实现高并发数据处理的有效手段之一
【9月更文挑战第2天】Kafka多线程Consumer是实现高并发数据处理的有效手段之一
1513 5
|
开发者 图形学 前端开发
绝招放送:彻底解锁Unity UI系统奥秘,五大步骤教你如何缔造令人惊叹的沉浸式游戏体验,从Canvas到动画,一步一个脚印走向大师级UI设计
【8月更文挑战第31天】随着游戏开发技术的进步,UI成为提升游戏体验的关键。本文探讨如何利用Unity的UI系统创建美观且功能丰富的界面,包括Canvas、UI元素及Event System的使用,并通过具体示例代码展示按钮点击事件及淡入淡出动画的实现过程,助力开发者打造沉浸式的游戏体验。
1033 0
|
Shell PHP Windows
【Azure App Service】Web Job 报错 UNC paths are not supported. Defaulting to Windows directory.
【Azure App Service】Web Job 报错 UNC paths are not supported. Defaulting to Windows directory.
321 0
|
消息中间件 Kafka 网络安全
【Azure Developer】在Azure VM (Windows) 中搭建 kafka服务,并且通过本地以及远程验证 发送+消费 消息
【Azure Developer】在Azure VM (Windows) 中搭建 kafka服务,并且通过本地以及远程验证 发送+消费 消息
262 0
|
Java 开发工具 Spring
【Azure Spring Cloud】使用azure-spring-boot-starter-storage来上传文件报错: java.net.UnknownHostException: xxxxxxxx.blob.core.windows.net: Name or service not known
【Azure Spring Cloud】使用azure-spring-boot-starter-storage来上传文件报错: java.net.UnknownHostException: xxxxxxxx.blob.core.windows.net: Name or service not known
296 0