ChangelogTopics¶

Creating Instance¶

ChangelogTopics takes the following to be created:

• InternalTopicManager
• Topic Groups (Map<Subtopology, TopicsInfo>)
• Tasks for Topic Groups (Map<Subtopology, Set<TaskId>>)
• Log Prefix

ChangelogTopics is created when:

• StreamsPartitionAssignor is requested to assignTasksToClients

setup¶

void setup()

setup...FIXME

setup is used when:

• StreamsPartitionAssignor is requested for consumer group assignment (and assignTasksToClients)