WindowedChangelogTopicConfig

WindowedChangelogTopicConfig is an InternalTopicConfig that…​FIXME

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

When created, WindowedChangelogTopicConfig creates a WINDOWED_STORE_CHANGELOG_TOPIC_DEFAULT_OVERRIDES configuration properties that…​FIXME

Creating WindowedChangelogTopicConfig Instance

WindowedChangelogTopicConfig takes the following when created:

  • Name

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

WindowedChangelogTopicConfig initializes the internal registries and counters.

setRetentionMs Method

void setRetentionMs(final long retentionMs)

setRetentionMs…​FIXME

Note
 setRetentionMs is used when…​FIXME

results matching ""

    No results matching ""