我是新来Kafka，当我们使用Kafka，我们可以设置retention.bytes。假设我们设置为1gb，如果消息量达到1gb，Kafka会删除消息。我想问一下，偏移量会被重置为零吗？其次，消费者将auto.offset.reset设置为最大，在kafka删除消息后，消费者将启动什么偏移量？
xxhby3vn1#
对于您的问题#1，如果同时遵守基于大小和基于时间的策略，日志可能会被滚动到一个新的空日志段。新日志段文件的起始偏移量将是附加到日志的下一条消息的偏移量。至于你的问题2，那要看情况了。如果消费者跟踪的偏移量由于消息删除而超出范围，则它将重置为最大偏移量。
1条答案
按热度按时间xxhby3vn1#
对于您的问题#1，如果同时遵守基于大小和基于时间的策略，日志可能会被滚动到一个新的空日志段。新日志段文件的起始偏移量将是附加到日志的下一条消息的偏移量。
至于你的问题2，那要看情况了。如果消费者跟踪的偏移量由于消息删除而超出范围，则它将重置为最大偏移量。