关于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消费者的命令的主要内容,如果未能解决你的问题,请参考以下文章