如果 kafka 消费者指定的偏移量不存在于 Broker 中，会发生什么情况？

Question

我是卡夫卡的新手。我想了解 kafka 消费者在其指定的偏移量不存在时的行为。可能由于保留策略或消费者指定了无效的偏移值，给定偏移量处的消息被删除。

Answer 1

您的消费者将使用您的auto.offset.reset设置将其偏移量重置为有效位置。如果未指定重置选项，则 Broker 将抛出InvalidOffsetException.

Answer 2

这取决于您配置的auto.offset.reset模式。请在下面找到有关当您寻求给定主题分区中不存在的偏移量时每种模式会发生什么的信息。

auto.offset.reset=最早

• 分区的偏移量将被重置为0并且所有消息将被消耗

auto.offset.reset=最新

• 分区的偏移量将重置为最后一个已知的偏移量，并且仅消耗新消息

自动偏移重置=无

• 消费者应用程序将因OffsetOutOfRangeException失败，如下所示，