BrokerServer¶

BrokerServer is a KafkaBroker that runs in KRaft mode.

Creating Instance¶

BrokerServer takes the following to be created:

• KafkaConfig
• MetaProperties
• RaftManager
• Time
• Metrics
• Optional threadNamePrefix
• Initial Offline Log Directories
• controllerQuorumVotersFuture (CompletableFuture[util.Map[Integer, AddressSpec]])
• Supported Features

BrokerServer is created when:

• KafkaRaftServer is created (with BrokerRole among the processRoles)

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¶

startup(): Unit

startup...FIXME

startup is used when:

• KafkaRaftServer is requested to startup