Explanation of the replication-bias checkpoint and recovery point correction in Kafka

Question

Can anyone explain what these files mean in the brokerage kafa logs.

root @ a2md23297l: / tmp / kafka-logs-1 # cat-point-offset-check-check-check_

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

Fyi, my-topic, kafkatopic_R2P1_1, my-topic, kafkatopic_R2P1, test - created topics. Thanks in advance.

Answer 1

AFAIK: recovery-point-offset-checkpoint - , Kafka , (- ) .

replication-offset-checkpoint , Kafka , (- ) .

. kafka/core/src/main/scala/kafka/server/LogOffsetMetadata.scala ReplicaManager.scala. .

Answer 2

.

(0- , ) (5- , )

(0- ) - , (----) -- ,