wxm*_*rio 3 apache-kafka kafka-consumer-api apache-zookeeper apache-kafka-connect
当我使用kafka0.8.x时,我可以通过路径获取所有带有zookeeper的组列表/consumers/group_id,因为偏移将在0.8.x中提交到zookeeper.
但是在0.10.x的版本中,offset提交给kafka代理,就像一个路径/brokers/topics/__consumer_offsets和/consumerszookeeper中的路径一样.所以我无法通过zookeeper获得消费者群体列表.
列出所有主题的所有消费者群组:
bin/kafka-consumer-groups.sh --bootstrap-server broker1:9092 --list
要查看使用者组的偏移量:
bin/kafka-consumer-groups.sh --bootstrap-server broker1:9092 --describe --group test-consumer-group
有关详细信息,请参阅管理使用者组
| 归档时间： |
|
| 查看次数： |
14911 次 |
| 最近记录： |