[jira] [Created] (CAMEL-8908) Kafka: Adapter causes Camel NotifyBuilder to throw a NullPointer exception

[RAHUL JAIN (JIRA)]

RAHUL JAIN created CAMEL-8908:
---------------------------------

             Summary: Kafka: Adapter causes Camel NotifyBuilder to throw a 
NullPointer exception
                 Key: CAMEL-8908
                 URL: https://issues.apache.org/jira/browse/CAMEL-8908
             Project: Camel
          Issue Type: Bug
          Components: camel-kafka
    Affects Versions: 2.15.2
            Reporter: RAHUL JAIN


Camel-kafka component (2.15.1) gives a NullPointer exception in NotifyBuilder 
causing our assertions to fail.

The error seems to be due to the fact that the Exchange created by the 
component has fromEndPoint set to null.

In KafkaEndpoint.java

   public Exchange createKafkaExchange(MessageAndMetadata<byte[], byte[]> mm) {
        Exchange exchange = new DefaultExchange(getCamelContext(), 
getExchangePattern());

I believe this should be instantiated as 
Exchange exchange = new DefaultExchange(this, getExchangePattern());



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)