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)