InternalTopicManager¶

Creating Instance¶

InternalTopicManager takes the following to be created:

• Time
• Admin (Apache Kafka)
• StreamsConfig

InternalTopicManager is created when:

• AssignorConfiguration is requested for an InternalTopicManager

makeReady¶

Set<String> makeReady(
  Map<String, InternalTopicConfig> topics)

makeReady...FIXME

makeReady is used when:

• ChangelogTopics is requested to setup
• RepartitionTopics is requested to setup