Skip to content

Latest commit

 

History

History
18 lines (11 loc) · 1.04 KB

kafka-streams-internals-UnwindowedChangelogTopicConfig.adoc

File metadata and controls

18 lines (11 loc) · 1.04 KB

UnwindowedChangelogTopicConfig

UnwindowedChangelogTopicConfig is an InternalTopicConfig that…​FIXME

UnwindowedChangelogTopicConfig is created exclusively when InternalTopologyBuilder is requested for create an InternalTopicConfig (for a given name and StateStoreFactory).

When created, UnwindowedChangelogTopicConfig creates a UNWINDOWED_STORE_CHANGELOG_TOPIC_DEFAULT_OVERRIDES configuration properties that…​FIXME

Creating UnwindowedChangelogTopicConfig Instance

UnwindowedChangelogTopicConfig takes the following when created:

  • Name

  • Topic configs (as Map<String, String>)

UnwindowedChangelogTopicConfig initializes the internal registries and counters.