ReplicaBuffer¶

Creating Instance¶

ReplicaBuffer takes the following to be created:

• Expected Replicas per TopicPartition (Map[TopicPartition, Int])
• Initial offsets (Map[TopicPartition, Long])
• Expected number of fetchers
• Report interval

ReplicaBuffer is created when:

• ReplicaVerificationTool is executed

Report Interval¶

ReplicaBuffer is given a report interval when created.

The value is --report-interval-ms and defaults to 30s.

The interval is used when verifyCheckSum to print out the following to the standard output:

[currentTimeMs]: max lag is [lag] for partition [partition] at offset [offset] among [n] partitions