我正在测试kafka-lag-exporer。我安装了kafka服务器,zookeper,我创建了一个名为topic_1
的Kafka主题和一个消费者组group1
,该消费者组从topic_1
读取消息。(均使用Kafka脚本)消费者组阅读了它们。然后我停止了消费者组的工作,并向topic_1
发送了更多的消息来制作滞后。一切正常,kafka-lag-exporter暴露的group="group1",topic="topic_1"
度量kafka_consumergroup_group_lag
然后我添加了一个名为topic_2的新主题,并在那里创建了一些消息,停止了消费者组,并创建了另外3条消息来制作滞后。现在没有group="group1",topic="topic_2"
的指标kafka_consumergroup_group_lag
。正如您在屏幕截图Kafka中所看到的那样,请显示消费者组group 1和主题topic_2.
的滞后
topic_1 active, topic_2 has lags的
然后我停止消费者组group1
阅读任何主题。
# TYPE kafka_consumergroup_group_lag gauge
kafka_consumergroup_group_lag{location="local",cluster_name="kafka",group="group1",topic="topic_1",partition="0",member_host="unknown",consumer_id="unknown",client_id="unknown",} 0.0
kafka_consumergroup_group_lag{location="local",cluster_name="kafka",group="group1",topic="topic_2",partition="0",member_host="unknown",consumer_id="unknown",client_id="unknown",} 3.0
字符串
stopped consumer group的
但是当我运行消费者组来消费一个主题时,我在滞后导出器中有这些指标
# HELP kafka_consumergroup_group_lag Group offset lag of a partition
# TYPE kafka_consumergroup_group_lag gauge
kafka_consumergroup_group_lag{location="local",cluster_name="kafka",group="group1",topic="topic_1",partition="0",member_host="/192.168.65.1",consumer_id="console-consumer-565052f6-8883-4594-831a-76e271b04edc",client_id="console-consumer",} 0.0
型
Kafka lag-exporter版本是0.7.0,它以独立模式运行,配置非常基本。
kafka-lag-exporter {
reporters.prometheus.port = 7070
clusters = [
{
name = "kafka"
bootstrap-brokers = "kafka:9092"
labels = {
location = "local"
}
}
]
}
型
你能帮帮我吗?
1条答案
按热度按时间bnl4lu3b1#
我通过改变一个工具解决了我的问题。我现在使用kafka_exporter而不是kafka-lag-exporter,即使没有活跃的消费者,它也会显示滞后。