Consumer LAG在Consumer Group中是什么意思答案

【问题标题】：What does consumer LAG mean in Consumer GroupConsumer LAG在Consumer Group中是什么意思
【发布时间】：2019-08-04 23:00:38
【问题描述】：

我观察到当 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-kafka kafka-consumer-api

【解决方案1】：

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

【讨论】：