检查卡夫卡的所有滞后

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个待处理的消息，所以这就是我得到的