Partition¶

readRecords¶

readRecords(
  lastFetchedEpoch: Optional[Integer],
  fetchOffset: Long,
  currentLeaderEpoch: Optional[Integer],
  maxBytes: Int,
  fetchIsolation: FetchIsolation,
  fetchOnlyFromLeader: Boolean,
  minOneMessage: Boolean): LogReadInfo

readRecords...FIXME

In the end, readRecords requests the Log to read messages.

readRecords is used when:

ReplicaManager is requested to readFromLocalLog

makeLeader¶

makeLeader(
  partitionState: LeaderAndIsrPartitionState,
  highWatermarkCheckpoints: OffsetCheckpoints,
  topicId: Option[Uuid]): Boolean

makeLeader...FIXME

makeLeader is used when:

ReplicaManager is requested to makeLeaders, applyLocalLeadersDelta

createLogIfNotExists¶

createLogIfNotExists(
  isNew: Boolean,
  isFutureReplica: Boolean,
  offsetCheckpoints: OffsetCheckpoints,
  topicId: Option[Uuid]): Unit

createLogIfNotExists...FIXME

createLogIfNotExists is used when:

Partition is requested to maybeCreateFutureReplica, makeLeader, makeFollower
ReplicaManager is requested to maybeAddLogDirFetchers, makeFollowers, applyLocalFollowersDelta

createLog¶

createLog(
  isNew: Boolean,
  isFutureReplica: Boolean,
  offsetCheckpoints: OffsetCheckpoints,
  topicId: Option[Uuid]): UnifiedLog

createLog...FIXME