ReplicaAlterLogDirsThread

ReplicaAlterLogDirsThread is a fetcher thread of ReplicaAlterLogDirsManager.

ReplicaAlterLogDirsThread is created when ReplicaAlterLogDirsManager is requested to create a fetcher thread.

ReplicaAlterLogDirsThread uses the following configuration properties.

Table 1. ReplicaAlterLogDirsThread’s Configuration Properties
Name Description

replica.fetch.backoff.ms

Used for fetchBackOffMs

broker.id

replica.fetch.response.max.bytes

replica.fetch.max.bytes

ReplicaAlterLogDirsThread has isOffsetForLeaderEpochSupported flag always enabled (true).

Creating ReplicaAlterLogDirsThread Instance

ReplicaAlterLogDirsThread takes the following to be created:

ReplicaAlterLogDirsThread initializes the internal registries and counters.

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

buildFetchForPartition Internal Method

buildFetchForPartition(
  tp: TopicPartition,
  fetchState: PartitionFetchState): ResultWithPartitions[Option[FetchRequest.Builder]]

buildFetchForPartition…​FIXME

Note
 buildFetchForPartition is used when ReplicaAlterLogDirsThread is requested to buildFetch.

results matching ""

    No results matching ""