似乎这个标题描述了我的问题。为什么? .timeindex inf-kafka存储的是相对偏移量,而不是实际位置或日志段的相对位置?
.timeindex
afdcj2ne1#
.timeindex文件可用于多种用途,如清理段文件(具有配置的时间保留)或响应使用者偏移请求。实际上,kafka使用者可以检索特定分区和unix时间戳的逻辑偏移量。经纪人将只使用timeindex来回答客户的问题。这将允许减少检索偏移量的磁盘访问。
1条答案
按热度按时间afdcj2ne1#
.timeindex文件可用于多种用途,如清理段文件(具有配置的时间保留)或响应使用者偏移请求。
实际上,kafka使用者可以检索特定分区和unix时间戳的逻辑偏移量。经纪人将只使用timeindex来回答客户的问题。这将允许减少检索偏移量的磁盘访问。