apache-kafka - 我想知道，当 startOffsetTime 的值为 kafka.api.OffsetRequest.EarliestTime() 时，偏移值是什么？

Question

当我设置startOffsetTime=kafka.api.OffsetRequest.LatestTime()时，偏移量的值是最大的可用值。

什么时候设置startOffsetTime is kafka.api.OffsetRequest.EarliestTime()偏移值？

Answer 1

有点难以理解你的问题。但无论如何，我想你是在问当你查询最早的偏移量时偏移量是多少。

Kafka 具有日志保留配置，允许为消息或日志文件大小设置生存时间。更多在这里。

假设您有一个将日志保留时间设置为 1 小时的主题，并且您生成了一些具有以下偏移量的消息：

0 1 2 3 4 5 6 7 8 9 10 ...

一小时后旧消息将从日志中删除，您可能会看到以下图片：

<offsets 0 1 2 3 4 no more exist in log> 5 6 7 8 9 10 ...

然后，当您查询最早的偏移量时，您将得到不再存在5的偏移量。0-4

这同样适用于log.retention.bytes配置，当您超过该配置值时，旧消息将被丢弃（实际上是整个段，但这对这个问题无关紧要）导致最早的偏移量高于0.