[jira] [Assigned] (KAFKA-9032) Serializer is invoked with null when foreignValue=null

["John Roesler (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

John Roesler reassigned KAFKA-9032:
-----------------------------------

    Assignee: John Roesler

> Serializer is invoked with null when foreignValue=null
> ------------------------------------------------------
>
>                 Key: KAFKA-9032
>                 URL: https://issues.apache.org/jira/browse/KAFKA-9032
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 2.4.0
>         Environment: MacOS X, Kafka Streams branch 1678a54.
>            Reporter: ghassan Yammine
>            Assignee: John Roesler
>            Priority: Blocker
>             Fix For: 2.4.0
>
>         Attachments: foreign-key-join-npe-stack-trace.txt
>
>
> I'm using the Ktable's foreign key join (ref: KIP-213).  When I try to *leftJoin* two KTables, and the left side's foreignKey does not have a key match in the right (other) KTable, the Join operation invokes the serializer with a foreignValue=null.  This then causes a NullPointerException in the provided (my) serializer.
> Stack Trace is attached.  Notes:
> {code:java}
> In method RecordCollectorImpl#send() (around line 97), inspecting 'value' shows:
> SubscriptionResponseWrapper{version=0, foreignValue=null, originalValueHash=[-5192323959200117799, -2503872568163857643]} {code}
> This foreignValue is passed to Serializer.java#serialize() as 'data'.  Ultimately, it ends up in SubscriptionResponseWrapperSerde#serialize (#72) where 'serliazedData` is null.  This is what is passed to my serializer.
> This exception is readily reproducible; just set up the left message-value to include a foreign key value that does not exist on the right side (the 'other' table).
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)