You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2021/05/10 20:09:00 UTC
[jira] [Assigned] (KAFKA-12749) Changelog topic config on
suppressed KTable lost
[ 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)