[
https://issues.apache.org/jira/browse/KAFKA-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-12749:
----------------------------------------------
Assignee: Viswanathan Ranganathan
> 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.8.0
> Reporter: Philip Bourke
> Assignee: Viswanathan Ranganathan
> Priority: Minor
> Labels: newbie, newbie++
> Fix For: 3.0.0, 2.8.1
>
>
> 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)
