Skip to content


BrokerServer is a KafkaBroker that runs in KRaft mode.

Creating Instance

BrokerServer takes the following to be created:

BrokerServer is created when:

Initial Offline Log Directories

initialOfflineDirs: Seq[String]

BrokerServer is given initialOfflineDirs when created (that is offlineDirs).

initialOfflineDirs is used to create a LogManager when BrokerServer is requested to startup.


startup(): Unit


startup is used when:

  • KafkaRaftServer is requested to startup