Skip to content

AutoTopicCreationManager

AutoTopicCreationManager is an abstraction of managers that can create topics.

Contract

createTopics

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

Used when:

shutdown

shutdown(): Unit

Used when:

start

start(): Unit

Used when:

  • BrokerServer is requested to startup
  • KafkaServer is requested to startup

Implementations

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