Skip to content

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:

makeLeader

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

makeLeader...FIXME


makeLeader is used when:

createLogIfNotExists

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

createLogIfNotExists...FIXME


createLogIfNotExists is used when:

createLog

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

createLog...FIXME