[KAFKA-8147] Add changelog topic configuration to KTable suppress

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 2.1.1
• Fix Version/s: 2.6.0
• Component/s: streams
• Labels: kip
• Assignee: highluck
• Reporter: Maarten
• Created: 22/Mar/19 13:10
• Updated: 09/May/21 00:43
• Resolved: 25/Feb/20 19:24

Description

The streams DSL does not provide a way to configure the changelog topic created by KTable.suppress.

From the perspective of an external user this could be implemented similar to the configuration of aggregate + materialized, i.e.,

changelogTopicConfigs = // Configs
materialized = Materialized.as(..).withLoggingEnabled(changelogTopicConfigs)
..
KGroupedStream.aggregate(..,materialized)

KIP-446: https://cwiki.apache.org/confluence/display/KAFKA/KIP-446%3A+Add+changelog+topic+configuration+to+KTable+suppress

Issue Links

• relates to: KAFKA-12749 Changelog topic config on suppressed KTable lost
• links to: GitHub Pull Request #6593
• links to: GitHub Pull Request #8029
• links to: GitHub Pull Request #8965
• mentioned in: Page Loading...
• mentioned in: Page Loading...
• mentioned in: Page Loading...