ReplicaAlterLogDirsThread

ReplicaAlterLogDirsThread is an uninterruptible AbstractFetcherThread that…​FIXME

ReplicaAlterLogDirsThread uses replica.fetch.backoff.ms configuration property for the fetchBackOffMs.

ReplicaAlterLogDirsThread is created exclusively when ReplicaAlterLogDirsManager is requested to create a fetcher thread (when…​FIXME).

ReplicaAlterLogDirsThread has isOffsetForLeaderEpochSupported flag always enabled (true).

fetchFromLeader Method

fetchFromLeader(
  fetchRequest: FetchRequest.Builder): Seq[(TopicPartition, FetchData)]
Note
fetchFromLeader is part of the AbstractFetcherThread Contract to…​FIXME.

fetchFromLeader…​FIXME

processPartitionData Method

processPartitionData(
  topicPartition: TopicPartition,
  fetchOffset: Long,
  partitionData: PartitionData[Records]): Option[LogAppendInfo]
Note
processPartitionData is part of the AbstractFetcherThread Contract to…​FIXME.

processPartitionData…​FIXME

truncateFullyAndStartAt Method

truncateFullyAndStartAt(
  topicPartition: TopicPartition,
  offset: Long): Unit
Note
truncateFullyAndStartAt is part of the AbstractFetcherThread Contract to…​FIXME.

truncateFullyAndStartAt…​FIXME

truncate Method

truncate(
  topicPartition: TopicPartition,
  truncationState: OffsetTruncationState): Unit
Note
truncate is part of the AbstractFetcherThread Contract to…​FIXME.

truncate…​FIXME

buildFetch Method

buildFetch(
  partitionMap: Map[TopicPartition, PartitionFetchState]
): ResultWithPartitions[Option[FetchRequest.Builder]]
Note
buildFetch is part of the AbstractFetcherThread Contract to…​FIXME

buildFetch…​FIXME

Creating ReplicaAlterLogDirsThread Instance

ReplicaAlterLogDirsThread takes the following to be created:

ReplicaAlterLogDirsThread initializes the internal registries and counters.

results matching ""

    No results matching ""