Table of Contents |
---|
Status
Current state: "Under Discussion"Accepted
Discussion thread: here
JIRA: KAKFA-3741
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
We will add the field and method described above to StreamsConfig. At topic creation time we will extract all properties from StreamsConfig that have the TOPIC_PREFIX and use these as the default configs when creating any internal topics. Any configs that are currently provided, i.e., via a StateStoreSupplier, will override any of the defaults that have been set in StreamsConfig.
Example Usage
Code Block |
---|
// use the topicPrefix static method config.put(StreamsConfig.topicPrefix(TopicConfig.SEGMENT_MS_CONFIG), "100"); // or use the "topic." prefix config.put(StreamsConfig.TOPIC_PREFIX + TopicConfig.COMPRESSION_TYPE_CONFIG, "gzip"), |
Compatibility, Deprecation, and Migration Plan
...