[
https://issues.apache.org/jira/browse/KAFKA-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12749:
-------------------------------------------
Labels: newbie newbie++ (was: )
> 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.0, 2.7.0, 2.6.1, 2.8.0, 2.6.2
> Reporter: Philip Bourke
> Priority: Minor
> Labels: newbie, newbie++
>
> 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)
