卡夫卡消费者(通过新消费者api创建)的偏移和滞后设置为未知。

Question

我经常看到卡夫卡消费者得到当前抵消和滞后设置为未知的问题。

较早的消费者有抵消和滞后。

GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER  
G.AB_KAFF, T.AB_KAFF, 0, 3, 6, 3, consumer-2
G.AB_KAFF, T.AB_KAFF, 1, 8, 11, 3, consumer-2

几天后，当我再次订阅这个用户时，它的偏移和滞后设置为未知。

GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER  
G.AB_KAFF, T.AB_KAFF, 0, unknown, 7, unknown, consumer-2
G.AB_KAFF, T.AB_KAFF, 1, unknown, 11, unknown, consumer-2  

卡夫卡是否删除了之前对该消费者的补偿，因为我不订阅整个消费群体的话题？

Answer 1

卡夫卡是否删除了之前对该消费者的补偿，因为我不订阅整个消费群体的话题？

是的，你是对的。offsets.retention.minutes=1440 (24 hours)默认为24小时。

日志保留窗口，以分钟为单位，用于偏移主题