有一些可以解释这些文件在kafka代理日志中的含义。在Kafka中解释复制偏移量检查点和恢复点偏移量
根@ a2md23297l：/ tmp目录/卡夫卡日志-1＃猫恢复点偏移检查点
我的话题0 0
kafkatopic_R2P1_1 0 0
我的话题1 0
kafkatopic_R2P1 0 0
试验0 0
根@ a2md23297l：/ TMP /卡夫卡-日志-1＃猫复制偏移检查点
我的话题0 0
kafkatopic_R2P1_1 0 2
我的话题1 0
kafkatopic_R2P1 0 2
试验0 57
据透露，我的话题，kafkatopic_R2P1_1，我的话题，kafkatopic_R2P1，测试是创建的主题。 在此先感谢。
AFAIK：recovery-point-offset-checkpoint是内部代理日志，其中Kafka跟踪哪些消息（从 - 到偏移量）已成功检查到磁盘。
replication-offset-checkpoint是内部经纪人日志，其中卡夫卡跟踪哪些消息（从 - 抵消）被成功复制到其他经纪人。
欲了解更多详情，你可以采取a deeper look在：kafka/core/src/main/scala/kafka/server/LogOffsetMetadata.scala和ReplicaManager.scala。代码评论相当不错。
Marko是现货。
开始两个数字（0-不知道这是什么）
号（即存在特定的磁盘分区的5号）旁边的主题名称（主题0-24分区号） 下一个数字是刷新到磁盘的偏移量（recovery-point-offset-checpoint）和复制偏移量检查点上一次偏移量，副本已成功复制数据