Kafka描述了显示不礼貌的组命令

Question

我使用卡夫卡0.10.2和动物园管理员3.4.9，我将我的补偿存储在卡夫卡经纪人。我在有5个分区的主题上运行3个消费者，所以为了检查延迟和所有我运行的命令

./kafka-使用者-groups.sh-引导-服务器本地主机:9092-描述-组group1

所以第一次的结果是

TOPIC                          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG        CONSUMER-ID                                       HOST                           CLIENT-ID
topic1         1          669             670             1          consumer-1-9417e05b-1cf9-4f0f-b6cd-61effdd09456   /127.0.0.1                     consumer-1
topic1         4          616             617             1          consumer-3-9ba9b12e-d6c2-423f-93cd-313906a2559c   /127.0.0.1                     consumer-3
topic1         2          628             706             78         consumer-2-22263f3a-bb8a-4305-a1c8-fbae9f190dda   /127.0.0.1                     consumer-2
topic1         3          695             697             2          consumer-2-6abb5b02-3ee8-4fd2-ade3-e10e3ce7d06f   /127.0.0.1                     consumer-2
topic1         0          11433           39381           27948      consumer-1-30b79487-4de8-40a4-951c-02f25e8976fc   /127.0.0.1                     consumer-1
-                              -          -               -               -          consumer-5-034e5889-dcc4-4cd1-975b-0d40a88899cf   /127.0.0.1                     consumer-5
-                              -          -               -               -          consumer-3-c10d695e-e067-428f-b31a-3a5318d60ef3   /127.0.0.1                     consumer-3
-                              -          -               -               -          consumer-4-090258c4-4d76-4cdd-8b62-f8fccf3ec097   /127.0.0.1                     consumer-4

运行1分钟后，相同的命令将显示此结果。

TOPIC                          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG        CONSUMER-ID                                       HOST                           CLIENT-ID
topic1         1          345             678             333        consumer-1-9417e05b-1cf9-4f0f-b6cd-61effdd09456   /127.0.0.1                     consumer-1
topic1         4          620             622             2          consumer-3-9ba9b12e-d6c2-423f-93cd-313906a2559c   /127.0.0.1                     consumer-3
topic1         2          708             708             0          consumer-2-22263f3a-bb8a-4305-a1c8-fbae9f190dda   /127.0.0.1                     consumer-2
topic1         3          545             701             156        consumer-2-6abb5b02-3ee8-4fd2-ade3-e10e3ce7d06f   /127.0.0.1                     consumer-2
topic1         0          11433           39385           27952      consumer-1-30b79487-4de8-40a4-951c-02f25e8976fc   /127.0.0.1                     consumer-1
-                              -          -               -               -          consumer-5-034e5889-dcc4-4cd1-975b-0d40a88899cf   /127.0.0.1                     consumer-5
-                              -          -               -               -          consumer-3-c10d695e-e067-428f-b31a-3a5318d60ef3   /127.0.0.1                     consumer-3
-                              -          -               -               -          consumer-4-090258c4-4d76-4cdd-8b62-f8fccf3ec097   /127.0.0.1                     consumer-4

在当前偏移量、滞后值和总偏移量(分区1)大于后一个one.Please之前，这是怎么可能的？

Answer 1

• 如果消费者使用seek()，它可以向后移动，从而使current offset变得更小。
• 不知道你说的“完全抵消”是什么意思？如果您引用log-end-offset而不是此偏移量，则如果将新数据写入主题分区(因此，它独立于实际的使用者组)，则偏移量会增加。
• 对于lag：这只是log-end-offset和current offset之间的区别。因此，由于current offset比以前小，而log-end-offset更大，所以它也更大。