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)
- relates to
-
KAFKA-12749 Changelog topic config on suppressed KTable lost
-
- Resolved
-
- links to
(2 mentioned in)