有人能解释这些文件的含义吗，这些文件存在于kafka代理日志中。
root@a2md23297l：/tmp/kafka-logs-1#cat恢复点偏移检查点
0
5
我的主题0
Kafka通病
我的主题10
Kafka通病
测试0
root@a2md23297l：/tmp/kafka-logs-1#cat复制偏移检查点
0
5
我的主题0
Kafka通病
我的主题10
Kafka通病
测试0 57
仅供参考，我的主题，kafkatopic\u r2p1\u 1，我的主题，kafkatopic\u r2p1，test是创建的主题。提前谢谢。
2条答案
按热度按时间wa7juj8i1#
马尔科很在行。
起始的两个数字（0-不确定这是什么）（5-特定磁盘上存在的分区数）
主题名称旁边的数字（0-主题的分区号）next number是刷新到磁盘的偏移量（恢复点偏移量checpoint）和复制偏移量检查点中复制副本成功复制数据的最后偏移量
biswetbf2#
阿法伊克：
recovery-point-offset-checkpoint是内部代理日志，kafka在其中跟踪哪些消息（从到偏移量）已成功检查点到磁盘。replication-offset-checkpoint是内部代理日志，kafka在其中跟踪哪些消息（从到偏移量）已成功复制到其他代理。有关更多详细信息，您可以更深入地了解：
kafka/core/src/main/scala/kafka/server/LogOffsetMetadata.scala以及ReplicaManager.scala. 代码注解得很好。