通过 kafka-consumer-groups.sh 脚本查看或变更消费组的信息。
查看消费者组信息
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
查看指定消费者组的消费位移
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group groupName
消费组一共有 Dead 、Empty 、PreparingRebalance 、CompletingRebalance 、Stable 这几种状态,正常情况下, 一个具有消费者成员的消费组的状态为Stable 。可以通过 state 参数来查看消费组当前的状态, 示例如下:
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group groupName --state
可以通过 members 参数罗列出消费组内的消费者成员信息,示例如下:文章来源:https://www.toymoban.com/news/detail-739768.html
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group groupName --members
在 --members 的基础上再增加一个 verbose 参数,那么还会罗列出每个消费者成员的分配情况,示例如下:文章来源地址https://www.toymoban.com/news/detail-739768.html
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group groupName --members --verbose
到了这里,关于kafka-consumer-groups.sh的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!