KafkaBroker¶

KafkaBroker is an abstraction of Kafka brokers.

Every KafkaBroker is a KafkaMetricsGroup.

Contract¶

LogManager¶

logManager: LogManager

LogManager

Used when:

• DynamicBrokerConfig is requested to addReconfigurables
• DynamicThreadPool is requested to reconfigure

Starting Up¶

startup(): Unit

Used when:

• KafkaServerTestHarness is requested to restartDeadBrokers and createBrokers

others¶

Implementations¶

• BrokerServer (for KRaft mode)
• KafkaServer