时间戳

首页 > 解决方案 > Consumer LAG在Consumer Group中是什么意思

apache-kafka - Consumer LAG在Consumer Group中是什么意思

问题描述

我观察到当 Producer 尝试发送消息时，Kafka Consumer 始终无法接收消息。当我检查 kafka 消费者时，看到了 LAG 值：

 docker run   --net=host   --rm <docker image> kafka-consumer-groups --zookeeper localhost:2181  --describe --group mgmt_testing

GROUP                          TOPIC    PARTITION   CURRENT-OFFSET  LOG-END-OFFSET    LAG             OWNER
mgmt_testing          mgmt_testing         0           44              44              0               mgmt_testing_aws-us-east-1-mr3-10-10-8-218-1561090200381-21858516-0
mgmt_testing          mgmt_testing          1          35              35              0               mgmt_testing_aws-us-east-1-mr3-10-10-8-218-1561090200381-21858516-0
mgmt_testing          mgmt_testing          2          39              39              0               mgmt_testing_aws-us-east-1-mr3-10-10-8-218-1561090200381-21858516-0
mgmt_testing          mgmt_testing          3          37              37              0               mgmt_testing_aws-us-east-1-mr3-10-10-8-218-1561090200381-21858516-0
mgmt_testing          mgmt_testing          4          25              38              13              mgmt_testing_aws-us-east-1-mr3-10-10-8-218-1561090200381-21858516-0
mgmt_testing          mgmt_testing          5          458             666             208             mgmt_testing_aws-us-east-1-mr3-10-10-8-218-1561090200381-21858516-0
mgmt_testing          mgmt_testing          6          808167          808181          14              mgmt_testing_aws-us-east-1-mr3-10-10-8-218-1561090200381-21858516-0
mgmt_testing          mgmt_testing          7          434028          434041          13              mgmt_testing_aws-us-east-1-mr3-10-10-8-218-1561090200381-21858516-0

LAG 在这里是什么意思？这会是消费者无法接收消息的原因吗？

标签： apache-kafkakafka-consumer-api

解决方案

本质上，延迟是这样一个事实，即在将消息发布到 Kafka 代理和使用它之间总会有一些延迟。sematext 的网站上有一个很好的描述：https ://sematext.com/blog/kafka-consumer-lag-offsets-monitoring/

推荐阅读