Table of Contents |
---|
Status
Current state: Under DiscussionAdopted
Discussion thread: [DISCUSS] KIP-446: Add changelog topic configuration to KTable suppress
JIRA:
Jira | ||||||||
---|---|---|---|---|---|---|---|---|
|
Implemented: 2.6.0
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
Code Block | ||
---|---|---|
| ||
public interface Suppressed<K> { interface BufferConfig<BC extends BufferConfig<BC>> { /** * Disable change logging for the currently suppressed records. the changelog for store built by this {@link StoreBuilder}. * This will turn off fault-tolerance for your store. * By default the changelog is enabled. * @return this */ BC withLoggingDisabled(); /** * Indicates that a changelog topic should be created containing the currently suppressed * records. Due to the short-lived nature of records in this topic it is likely more * compactable than changelog topics for KTables. * * @param config Configs that should be applied to the changelog. Note: Any unrecognized * configs will be ignored. * @return itselfthis */ BC withLoggingEnabled(final Map<String, String> config); } } |
...