我想知道，当startOffsetTime的值是kafka.api.OffsetRequest.EarliestTime（）。偏移值是什么？

Question

当我设置​​时，偏移值是可用的最大值。

设置时startOffsetTime is kafka.api.OffsetRequest.EarliestTime()补偿值是多少？

Answer 1

很难理解你的问题。但无论如何，我想你问的是，当你查询最早的偏移量时将会出现什么偏移量。

Kafka具有日志保留配置，允许为消息或日志文件大小设置生存时间。 More here。

想象一下，你有设置为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。