AutoTopicCreationManager¶

AutoTopicCreationManager is an abstraction of managers that can create topics.

Contract¶

createTopics¶

createTopics(
  topicNames: Set[String],
  controllerMutationQuota: ControllerMutationQuota): Seq[MetadataResponseTopic]

Used when:

KafkaApis is requested to getTopicMetadata and handleFindCoordinatorRequest

shutdown¶

shutdown(): Unit

Used when:

BrokerServer is requested to shutdown
KafkaServer is requested to shutdown

start¶

start(): Unit

Used when:

BrokerServer is requested to startup
KafkaServer is requested to startup

Implementations¶

DefaultAutoTopicCreationManager

Creating AutoTopicCreationManager¶

apply(
  config: KafkaConfig,
  metadataCache: MetadataCache,
  time: Time,
  metrics: Metrics,
  threadNamePrefix: Option[String],
  adminManager: Option[ZkAdminManager],
  controller: Option[KafkaController],
  groupCoordinator: GroupCoordinator,
  txnCoordinator: TransactionCoordinator,
  enableForwarding: Boolean): AutoTopicCreationManager

apply creates a DefaultAutoTopicCreationManager.

apply is used when:

KafkaServer is requested to startup