ReplicaAlterLogDirsManager

ReplicaAlterLogDirsManager is a AbstractFetcherManager of ReplicaAlterLogDirsThreads with the properties.

Table 1. ReplicaAlterLogDirsThreads' Configuration Properties
Name Description

name

ReplicaAlterLogDirsManager on broker [brokerId]

clientId

ReplicaAlterLogDirs

numFetchers

KafkaConfig.getNumReplicaAlterLogDirsThreads

ReplicaAlterLogDirsManager is created for ReplicaManager.

Creating ReplicaAlterLogDirsManager Instance

ReplicaAlterLogDirsManager takes the following to be created:

Creating ReplicaAlterLogDirsThread — createFetcherThread Method

createFetcherThread(
  fetcherId: Int,
  sourceBroker: BrokerEndPoint): ReplicaAlterLogDirsThread
Note
createFetcherThread is part of the AbstractFetcherManager contract to create a fetcher thread.

createFetcherThread creates a ReplicaAlterLogDirsThread with the thread name as ReplicaAlterLogDirsThread-[fetcherId].

shutdown Method

shutdown(): Unit

shutdown prints out the following INFO message to the logs:

shutting down

shutdown closeAllFetchers.

In the end, shutdown prints out the following INFO message to the logs:

shutdown completed
Note
shutdown is used when ReplicaManager is requested to shut down.

results matching ""

    No results matching ""