1.概述

转载：https://blog.csdn.net/lukabruce/article/details/89210463

今天在查询kafka检查消费者位置时运行

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic test2 --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181

然后报错如下：

Error: Could not find or load main class kafka.tools.ConsumerOffsetChecker

经过检查发现kafka在0.9.0.0版本之后，kafka.tools.ConsumerOffsetChecker已经不支持了。

应该使用kafka.admin.ConsumerGroupCommand(或bin/kafka-consumer-groups.sh脚本)来管理消费者组，

包括用新消费者API创建的消费者。

新命令如下：

//查看所有组

${KAFKA_HOME}/bin/kafka-consumer-groups.sh --bootstrap-server ip:9092 --list //查看具体组的详细描述信息
${KAFKA_HOME}/bin/kafka-consumer-groups.sh --bootstrap-server 192.168.47.133:9092 --describe --group groupname指定自己的分组 自己消费的topic会显示kafka总共有多少数据，以及已经被消费了多少条
结果：GROUP     TOPIC     PID         OFFSET           LOGSIZE        LAG
消费者组  话题id    分区id    当前已消费的条数         总条数    未消费的条数

注意：以kafkaspout类作为消费者去读kafka数据，相当于直接从kafka server上取文件，没有消费者组的概念
每次读的数据存在自己zk的offet中，所以不能通过上述命令查看

【Kafka】Could not find or load main class kafka.tools.ConsumerOffsetChecker相关推荐

【Centos】EFAK（kafka-eagle）对ZK、Kafka可视化管理工具容器化安装与配置
[Centos]EFAK(kafka-eagle)对ZK.Kafka可视化管理工具容器化安装与配置前言构建 Dockerfile system-config.properties works re ...
【原创】大叔问题定位分享（4）Kafka集群broker节点从zookeeper上消失
kafka_2.8.0-0.8.1 一现象生产环境一组kafka集群经常发生问题,现象是kafka在zookeeper上的broker节点消失,此时kafka进程和端口都在,然后每个broker都 ...
【Druid】（八）Apache Druid 核心插件 Kafka Indexing Service SLS Indexing Service
文章目录一.前言二.与 Kafka 集群交互三.使用 Apache Druid Kafka Indexing Service 实时消费 Kafka 数据四.关于 SLS Indexing Se ...
【转载】Understanding When to use RabbitMQ or Apache Kafka
https://content.pivotal.io/rabbitmq/understanding-when-to-use-rabbitmq-or-apache-kafka RabbitMQ: Erl ...
【iis】解决：Could not load type ‘System.ServiceModel.Activation.HttpModule‘ from assemb
解决:Could not load type 'System.ServiceModel.Activation.HttpModule' from assemb 发布 .svc 项目,获取运行出错如下: ...
【转】关于提示can't load package 'xxx.bpl.' 错误问题的解决方法
转自: http://blog.sina.com.cn/s/blog_44fa172f0102v9x3.html 'xxx.bpl'包实际存在, 路径并且正确. 但是总提示'can't load pa ...
【Hadoop】解决Hadoop Unable to load native-hadoop library问题
1.启动Hadoop提示WARN util.NativeCodeLoader: Unable to load native-hadoop library for your platform- usin ...
【flink】flink 消费组死掉 Lag不变 kafka不提交重启恢复非常诡异
文章目录 1.场景1 1.1 钙素 2.场景2 2.场景2 1.场景1 1.1 钙素是这样的,我有一个环境,遇到一个这样的现象,flink任务运行了 13天了,然后看消费组状态的时候发现lag很大 ...
zynq7000创建fsbl启动_【转】Zynq启动过程探讨-进入main函数前不了解的事-Zynq-7000系列-米尔科技论坛...
写在前面: 本人纯属菜鸟,不敢保证自己的观点正确,各位看官多指教. 本文讨论的主题是zynq启动过程. 阅读本文要对Zyna EPP有那么一点点了解,最好使用过Xilinx的PlanAhead.EDK ...

【Kafka】Could not find or load main class kafka.tools.ConsumerOffsetChecker

1.概述

【Kafka】Could not find or load main class kafka.tools.ConsumerOffsetChecker相关推荐

最新文章

热门文章