关于kafka消费者的命令

发布网友发布时间：2022-11-27 10:13

共1个回答

热心网友时间：2023-10-16 08:22

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 mole 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，即没有识别到消费进程。
那看源码吧