You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "RAHUL JAIN (JIRA)" <ji...@apache.org> on 2015/06/27 08:37:04 UTC

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

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)