Skip to content

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

Note

There are other methods.

Implementations