Kafka OffsetOutOfRangeException 即使偏移量 ID 为零答案

【问题标题】：Kafka OffsetOutOfRangeException even for offset ID zeroKafka OffsetOutOfRangeException 即使偏移量 ID 为零
【发布时间】：2020-10-19 18:10:51
【问题描述】：

我的应用程序正在尝试从零偏移量轮询记录，但我遇到了错误

org.apache.kafka.clients.consumer.OffsetOutOfRangeException

我正在使用简单的 apache 消费者代码，例如 this ，通常当我使用带有数字的偏移量进行轮询并且它在 kafka 代理中被删除或不存在时会出现此错误。所以任何想法为什么这个错误即使是offest 0

【问题讨论】：

标签： apache-kafka kafka-consumer-api

【解决方案1】：

正如你所说，当请求的偏移量在 Kafka 中不再存在时会发生此错误。

偏移量 0 没有什么不同。当达到保留限制时，它可以像任何其他偏移量一样被删除。

您可以使用消费者的 beginningOffsets() 或管理员的 listOffsets() API 来查找主题的开始偏移量。

【讨论】：