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 为什么要抛弃 Zookeeper?
本文探讨了Kafka为何逐步淘汰ZooKeeper。长久以来,ZooKeeper作为Kafka的核心组件,负责集群管理和协调任务。然而,随着Kafka的发展,ZooKeeper带来的复杂性增加、性能瓶颈及一致性问题日益凸显。为解决这些问题,Kafka引入了KRaft,这是一种基于Raft算法的内置元数据管理方案,不仅简化了部署流程,还提升了系统的一致性和扩展性。本文详细分析了这一转变背后的原因及其带来的优势,并展望了Kafka未来的发展方向。
1193 1
|
消息中间件 运维 Java
搭建Zookeeper、Kafka集群
本文详细介绍了Zookeeper和Kafka集群的搭建过程,涵盖系统环境配置、IP设置、主机名设定、防火墙与Selinux关闭、JDK安装等基础步骤。随后深入讲解了Zookeeper集群的安装与配置,包括数据目录创建、节点信息设置、SASL认证配置及服务启动管理。接着描述了Kafka集群的安装,涉及配置文件修改、安全认证设置、生产消费认证以及服务启停操作。最后通过创建Topic、发送与查看消息等测试验证集群功能。全网可搜《小陈运维》获取更多信息。
1118 1
|
消息中间件 监控 Ubuntu
大数据-54 Kafka 安装配置 环境变量配置 启动服务 Ubuntu配置 ZooKeeper
大数据-54 Kafka 安装配置 环境变量配置 启动服务 Ubuntu配置 ZooKeeper
561 3
大数据-54 Kafka 安装配置 环境变量配置 启动服务 Ubuntu配置 ZooKeeper
|
消息中间件 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 基础概念了解
494 4
|
消息中间件 Java Kafka
windows服务器重装系统之后,Kafka服务如何恢复?
windows服务器重装系统之后,Kafka服务如何恢复?
330 8
|
存储 Shell 开发工具
8-8|windows上Git报错
8-8|windows上Git报错
|
消息中间件 安全 大数据
Kafka多线程Consumer是实现高并发数据处理的有效手段之一
【9月更文挑战第2天】Kafka多线程Consumer是实现高并发数据处理的有效手段之一
1530 5
|
消息中间件 Java Kafka
ELFK对接zookeeper&kafka
ELFK对接zookeeper&kafka