檢查卡夫卡的所有滯後

Question

我想確保即使消費者沮喪，我也不會在卡夫卡上丟失任何消息。

如果我有一個小時的日誌，如果我的消費者關閉了一個多小時，我將丟失未被消費的消息。

是否有任何方法可以輕鬆地檢查卡夫卡0.10.2.0中所有分區的所有滯後？

我發現很多方法都無法正常工作。

Answer 1

您可以使用kafka-consumer-groups.sh命令來查找滯後。

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group group1 

在這個例子中我說讓我所有的主題，1組是聽和最新的滯後，我消費了下來最後幾分鐘。並且它有4個待處理的消息，所以這就是我得到的