保留配置偏移之间的差异。保持会议记录和日志。保持分钟

偏移量是指向消费者已使用的最新消息的指针。因此,如果您阅读10条消息,偏移量会移动10个位置。 offsets.retention.minutes 允许您在设定的时间段内未更改偏移量时将其移回起始位置。

为了形象化,我们假设 a 到 g (按顺序)在卡夫卡主题中,在不同的时间。在开始使用消息之前,偏移量指向最旧的消息:

OFFSET:    *
MESSAGES:  a b c d e f g

现在我们使用3条消息( 一 , b , c )因此偏移量移动:

OFFSET:          *
MESSAGES:  a b c d e f g

现在让我们假装 log.retention.minutes=10 ,我们把 一 和 b 11分钟前进入主题,但其他消息是最近插入的。我们会看到:

OFFSET:          *
MESSAGES:      c d e f g

现在让我们开始 offsets.retention.minutes=1 ,然后假装我们上次吃东西已经90秒了。我们会看到:

OFFSET:        *  
MESSAGES:      c d e f g

因为 c 现在是该主题上最早的消息(也是第一条将被使用的消息)。