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/04 23:40:00 UTC
[jira] [Updated] (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 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)