Philip Bourke created KAFKA-12749:
-------------------------------------
Summary: Changelog topic config on suppressed KTable lost
Key: KAFKA-12749
URL: https://issues.apache.org/jira/browse/KAFKA-12749
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 2.6.2, 2.8.0, 2.6.1, 2.7.0, 2.6.0
Reporter: Philip Bourke
When trying to set the changelog configuration on a suppressed KTable, the
config is lost if either {{emitEarlyWhenFull}} or {{shutDownWhenFull}} is set
after the logging config.
This works -
{code:java}
.suppress(Suppressed.untilTimeLimit(Duration.ofMillis(maxIdleIntervalMs),
BufferConfig.maxRecords(
maxBufferRecords).emitEarlyWhenFull().withLoggingEnabled(changelogConfig)){code}
but not if you set {{emitEarlyWhenFull}} last.
See comments in https://issues.apache.org/jira/browse/KAFKA-8147
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
