当我设置 startOffsetTime=kafka.api.OffsetRequest.LatestTime() ，偏移量的值是可用的最大值。设置时 startOffsetTime is kafka.api.OffsetRequest.EarliestTime() 偏移值是多少？
startOffsetTime=kafka.api.OffsetRequest.LatestTime()
startOffsetTime is kafka.api.OffsetRequest.EarliestTime()
vwkv1x7d1#
你的问题很难理解一点。但不管怎样，我想当你查询最早的偏移量时，你会问偏移量是多少。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 config，当您超过该配置值时，较旧的消息将被丢弃（实际上是整个段，但这对于这个问题并不重要），导致最早的偏移量高于 0 .
5
0-4
log.retention.bytes
0
1条答案
按热度按时间vwkv1x7d1#
你的问题很难理解一点。但不管怎样，我想当你查询最早的偏移量时，你会问偏移量是多少。
kafka有日志保留配置，允许为消息或日志文件大小设置生存时间。这里有更多。
假设您有一个日志保留时间设置为1小时的主题，并生成一些偏移量如下的消息：
一小时后，旧邮件将从日志中删除，您可能会看到以下图片：
然后，当您将查询最早的抵消，你会得到
5作为偏移量0-4不再存在。这同样适用于
log.retention.bytesconfig，当您超过该配置值时，较旧的消息将被丢弃（实际上是整个段，但这对于这个问题并不重要），导致最早的偏移量高于0.