ControllerChannelManager

ControllerChannelManager is…​FIXME

ControllerChannelManager is created exclusively when KafkaController is requested to startChannelManager.

Table 1. ControllerChannelManager’s Metrics
Name Description

TotalQueueSize

Table 2. ControllerChannelManager’s Internal Properties
Name Description

brokerStateInfo

Used when…​FIXME

brokerLock

Used when…​FIXME

ControllerChannelManager uses [Channel manager on controller [brokerId]] as the logging prefix (aka logIdent).

addNewBroker Internal Method

addNewBroker(broker: Broker): Unit

addNewBroker…​FIXME

Note
addNewBroker is used when ControllerChannelManager is created (to connect to live brokers) and is requested to addBroker.

addBroker Method

addBroker(broker: Broker): Unit

addBroker…​FIXME

Note
addBroker is used exclusively when BrokerChange controller event is processed.

Creating ControllerChannelManager Instance

ControllerChannelManager takes the following when created:

  • ControllerContext

  • KafkaConfig

  • Time

  • Metrics

  • StateChangeLogger

  • Optional thread name prefix (default: None)

ControllerChannelManager initializes the internal registries and counters.

In the end, ControllerChannelManager requests the ControllerContext for the liveBrokers that it addNewBroker each.

results matching ""

    No results matching ""