如果我指定了一个timestamp，Kafka怎么查找到对应的消息？
发布于 2020-05-19 18:13:20
关注者
0
被浏览
702
1 个回答
-
1.通过文件名前缀数字x找到该绝对offset 对应消息所在文件 2.offset-x为在文件中的相对偏移 3.通过index文件中记录的索引找到最近的消息的位置 4.从最近位置开始逐条寻找
原理同上 但是时间的因为消息体中不带有时间戳 所以不精确
