[ https://issues.apache.org/jira/browse/KAFKA-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
John Roesler reassigned KAFKA-8824: ----------------------------------- Assignee: John Roesler > InMemoryTimeOrderedKeyValueBuffer propagates nulls when supress is configured > ------------------------------------------------------------------------------ > > Key: KAFKA-8824 > URL: https://issues.apache.org/jira/browse/KAFKA-8824 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 2.3.0, 2.4.0 > Reporter: Ferran altimiras > Assignee: John Roesler > Priority: Major > Fix For: 2.4.0, 2.3.1 > > Attachments: Test.java > > > Maybe this is not a bug, but it looks like something is wrong. This didn't > happen in kafka streams 2.2. > > Applying an aggregate() with suppress on kafka 2.3 sends nulls into > Serializer if delayed msgs are received. > Not sure if some data is lost or not(yet). But IMHO getting a null to > serialize the "accumulator" object is suspicious that something is wrong. > > Attached java code to demonstrate it. > With kafka 2.3 -> LongSerde prints NULL, not in kafka 2.2 > > > > -- This message was sent by Atlassian Jira (v8.3.2#803003)