[jira] [Commented] (KAFKA-8824) InMemoryTimeOrderedKeyValueBuffer propagates nulls when supress is configured

["Ferran altimiras (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16912169#comment-16912169 ] 

Ferran altimiras commented on KAFKA-8824:
-----------------------------------------

Hi [~guozhang], could be related to your last improvements? Regards

> 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
>            Priority: Major
>         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)