Replica (aka partition replica) is…​FIXME

Replica is a local partition replica when the replica ID is the local broker ID.

Replica is a future local replica when the replica ID is -3.

Replica is created exclusively when Partition is requested to getOrCreateReplica.

Replica is local when the Log was defined (at the time the replica was created).


Enable INFO or TRACE logging level for kafka.cluster.Replica logger to see what happens inside.

Add the following line to config/


Refer to Logging.

latestEpoch Method

latestEpoch: Option[Int]


latestEpoch is used when…​FIXME

Creating Replica Instance

Replica takes the following to be created:

  • Broker ID

  • TopicPartition

  • Time (default: SYSTEM)

  • initialHighWatermarkValue (default: 0L)

  • Optional Log (default: None)

Replica initializes the internal registries and counters.

While being created, Replica prints out the following INFO message to the logs and requests the Log to onHighWatermarkIncremented with the given initialHighWatermarkValue.

Replica loaded for partition [topicPartition] with initial high watermark [initialHighWatermarkValue]

results matching ""

    No results matching ""