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

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.15.2
• Fix Version/s: 2.15.3, 2.16.0, 2.14.4
• Component/s: camel-kafka
• Patch Info: Patch Available
• Estimated Complexity: Unknown
• Flags: Patch
• Assignee: Claus Ibsen
• Reporter: RAHUL JAIN
• Created: 27/Jun/15 06:36
• Updated: 28/Jun/15 08:53
• Resolved: 28/Jun/15 08:53

Description

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());