THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Table of Contents |
---|
Status
Current state: "Under Discussion"Accepted
Discussion thread: here
JIRA: KAKFA-3741
...
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
...