ReplicaFetcherThread

ReplicaFetcherThread is a AbstractFetcherThread…​FIXME

ReplicaFetcherThread is created exclusively when ReplicaFetcherManager is requested to create one (when…​FIXME).

Creating ReplicaFetcherThread Instance

ReplicaFetcherThread takes the following when created:

ReplicaFetcherThread initializes the internal registries and counters.

earliestOrLatestOffset Internal Method

earliestOrLatestOffset(topicPartition: TopicPartition, earliestOrLatest: Long): Long

earliestOrLatestOffset…​FIXME

Note
earliestOrLatestOffset is used when…​FIXME

fetchEpochsFromLeader Method

fetchEpochsFromLeader(partitions: Map[TopicPartition, Int]): Map[TopicPartition, EpochEndOffset]
Note
fetchEpochsFromLeader is a part of AbstractFetcherThread Contract.

fetchEpochsFromLeader…​FIXME

Note
fetchEpochsFromLeader is used when…​FIXME

results matching ""

    No results matching ""