卡夫卡的消費群體

此工具允許你列出，描述或刪除使用者組。有關消費者組的更多資訊，請檢視本文 。

如果你仍然使用舊的消費者實現，請將 --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