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