ReplicaFetcherManager is a AbstractFetcherManager that…​FIXME (describe properties)

ReplicaFetcherManager is created exclusively when ReplicaManager is requested to create one (which is when ReplicaManager is created).

createFetcherThread Method

createFetcherThread(fetcherId: Int, sourceBroker: BrokerEndPoint): AbstractFetcherThread


createFetcherThread is used exclusively when AbstractFetcherManager addFetcherForPartitions

Creating ReplicaFetcherManager Instance

ReplicaFetcherManager takes the following when created:

ReplicaFetcherManager initializes the internal registries and counters.

results matching ""

    No results matching ""