检查Kafka所有的滞后

ruarlubt 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(281)

我想确保我没有丢失Kafka的任何信息，即使我的消费者已经失望了。
如果我有一个小时的日志记录，如果我的消费者停机超过一个小时，我将丢失未被消费的消息。
在Kafka0.10.2.0中，有没有什么方法可以轻松地检查所有分区的所有延迟？
我发现很多方法都不管用。

1条答案

您可以使用kafka-consumer-groups.sh命令来查找延迟。

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

在这个例子中，我的意思是显示group1正在收听的所有主题以及延迟是什么，我的消费者在过去的几分钟里一直在下降，它有4条等待处理的消息，所以这就是我得到的