You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Bharath Kumarasubramanian (JIRA)" <ji...@apache.org> on 2018/10/30 19:53:00 UTC

[jira] [Created] (SAMZA-1971) Fix NPE in InMemorySystemProducer when message is null

Bharath Kumarasubramanian created SAMZA-1971:
------------------------------------------------

             Summary: Fix NPE in InMemorySystemProducer when message is null
                 Key: SAMZA-1971
                 URL: https://issues.apache.org/jira/browse/SAMZA-1971
             Project: Samza
          Issue Type: Bug
            Reporter: Bharath Kumarasubramanian
            Assignee: Bharath Kumarasubramanian
             Fix For: 1.0


For changelog topics, a delete on the record corresponds to an outgoing message envelope with valid key and null message. InMemorySystemProducer should handle it correctly as opposed to throwing NPE

The order in which partition key is chosen is as follows
 # If the partition key exists as part of OutgoingMessageEnvelope use it to compute partition hash
 # If partitionKey is null, use the message key to compute partition hash
 # If both partitionKey and messageKey is absent, use message to compute the partition key

We throw exception the resulting key to compute hash code is still null.

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)