Skip to content

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:

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