[
https://issues.apache.org/jira/browse/KAFKA-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16912802#comment-16912802
]
John Roesler commented on KAFKA-8824:
-------------------------------------
Ok, here's the patch: https://github.com/apache/kafka/pull/7235
> 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
> 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)
