关于kafka消费者的命令

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了关于kafka消费者的命令相关的知识,希望对你有一定的参考价值。

参考技术A sh kafka-consumer-groups.sh --bootstrap-server "ip:端口,ip:端口,ip:端口" --group 订阅组 --describe
我在本地idea起了两个进程
那么CONSUMER-ID会有两个,但是CLIENT-ID依旧是一个。
怀疑CLIENT-ID如果ip不同的话,会不同。那这样的话我重新打个jar包放到其他地方执行,是否就会显示不一样呢?
通过idea的
File -->Project Structure -->Artifacts --> Jar --> From module with dependencies.
Build --> Build Artifacts
等一通操作生成了jar包放在了其他机器上跑
发现CLIENT-ID依然一样

另外测试过sh kafka-console-consumer.sh --bootstrap-server "xx" --topic xx
消费数据时,再使用sh kafka-consumer-groups.sh 来检查,并不会有关于CONSUMER-ID和CLIENT-ID,即没有识别到消费进程。
那看源码吧

以上是关于关于kafka消费者的命令的主要内容,如果未能解决你的问题,请参考以下文章

关于kafka更改消费者对应分组下的offset值

python操作kafka

五 通过命令行了解 Kafka消费者组

请教一个关于使用spark 读取kafka只能读取一个分区数据的问题

关于kafka重新消费数据问题

关于怎么获取kafka指定位置offset消息(转)