[jira] [Created] (KAFKA-12841) NPE from the provided metadata in client callback in case of ApiException

["Avi Youkhananov (Jira)" <ji...@apache.org>]

Avi Youkhananov created KAFKA-12841:
---------------------------------------

             Summary: NPE from the provided metadata in client callback in case of ApiException
                 Key: KAFKA-12841
                 URL: https://issues.apache.org/jira/browse/KAFKA-12841
             Project: Kafka
          Issue Type: Bug
          Components: clients
    Affects Versions: 2.6.0
         Environment: Prod
            Reporter: Avi Youkhananov
         Attachments: NPE.production

1.
org.apache.kafka.clients.producer.Callback interface has method onCompletion(...)
Which says as part of the documentation :

*The metadata for the record that was sent (i.e. the partition and offset). *An empty metadata with -1 value for all fields* except for topicPartition will be returned if an error occurred.


We got an NPE from doSend(...) method in org.apache.kafka.clients.producer.KafkaProducer 
Which can occur in case ApiException was thrown ...
In case of ApiException it uses the regular callback instead of InterceptorCallback which also may cover the NPE.

2. More over RecordMetadata has method partition() which return int but can also throw NPE because TopicPartition might be null.

Stack trace attached.

 



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