5

有人可以解释这些文件的含义,存在于 kafka 代理日志中。

root@a2md23297l:/tmp/kafka-logs-1# cat recovery-point-offset-checkpoint
0
5
my-topic 0 0
kafkatopic_R2P1_1 0 0
my-topic 1 0
kafkatopic_R2P1 0 0
test 0 0
root@a2md23297l:/tmp/kafka -logs-1# cat replication-offset-checkpoint
0
5
my-topic 0 0
kafkatopic_R2P1_1 0 2
my-topic 1 0
kafkatopic_R2P1 0 2
test 0 57

仅供参考,my-topic, kafkatopic_R2P1_1 ,my-topic,kafkatopic_R2P1,test是创建的主题。提前致谢。

4

2 回答 2

8

AFAIK:recovery-point-offset-checkpoint是内部代理日志,其中 Kafka 跟踪哪些消息(从到偏移)已成功检查点到磁盘。

replication-offset-checkpoint是内部代理日志,Kafka 跟踪哪些消息(从到偏移)成功复制到其他代理。

有关更多详细信息,您可以更深入地了解kafka/core/src/main/scala/kafka/server/LogOffsetMetadata.scalaReplicaManager.scala。代码注释得很好。

于 2016-02-15T12:25:57.947 回答
3

马尔科是正确的。

开始的两个数字(0 - 不确定这是什么)(5 - 该特定磁盘上存在的分区数)

主题名称旁边的数字(0-主题的分区号)下一个数字是刷新到磁盘的偏移量(recovery-point-offset-checpoint)和replication-offset-checkpoint中副本成功复制的最后一个偏移量数据

于 2016-05-16T23:08:51.033 回答