卡夫卡的消费群体

此工具允许你列出，描述或删除使用者组。有关消费者组的更多信息，请查看本文 。

如果你仍然使用旧的消费者实现，请将 --bootstrap-server 替换为 --zookeeper。

列出消费者群体：

kafka-consumer-groups  --bootstrap-server localhost:9092 --list
octopus

描述一个消费者群体：

kafka-consumer-groups  --bootstrap-server localhost:9092 --describe --group octopus
GROUP          TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG       OWNER
octopus        test-topic      0          15              15              0         octopus-1/127.0.0.1
octopus        test-topic      1          14              15              1         octopus-2_/127.0.0.1

备注 ：在上面的输出中，

• current-offset 是消费者实例的最后一个提交的偏移量，
• log-end-offset 是分区的最高偏移量（因此，汇总此列可为你提供主题的消息总数）
• lag 是当前消费者偏移和最高偏移之间的差异，因此消费者的落后程度是多少，
• owner 是消费者的 client.id（如果未指定，则显示默认值）。

删除使用者组：

删除仅在组元数据存储在 zookeeper（旧的消费者 api）中时可用。使用新的使用者 API，代理处理包括元数据删除在内的所有内容：当组的最后一个提交的偏移量到期时，将自动删除该组。

kafka-consumer-groups --bootstrap-server localhost:9092 --delete --group octopus