gpt4 book ai didi

apache-kafka - 检查Kafka中的所有滞后

转载 作者:行者123 更新时间:2023-12-04 04:24:11 24 4
gpt4 key购买 nike

我想确保即使我的消费者宕机,我也不会在 Kafka 中丢失任何消息。

如果我有一个小时的日志滚动,如果我的消费者停机超过一小时,我将丢失未被消费的消息。

有没有办法在 Kafka 0.10.2.0 中轻松检查所有分区的所有滞后?

我发现很多方法都没有奏效。

最佳答案

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

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

在这个例子中,我是说向我展示 group1 正在收听的所有主题以及延迟是什么,我的消费者在最后几分钟处于关闭状态。它有 4 条待处理的消息,所以这就是我得到的
enter image description here

关于apache-kafka - 检查Kafka中的所有滞后,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42838012/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com