[CAMEL-7306] Camel:Kafka NPE when trying to consume messages from kafka server

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.13.1
• Fix Version/s: 2.13.1, 2.14.0
• Component/s: camel-kafka

Environment

Windows, Java 1.6

• Estimated Complexity: Unknown
• Assignee: Grzegorz Grzybek
• Reporter: Ilya Melnik
• Created: 18/Mar/14 10:14
• Updated: 04/May/14 08:45
• Resolved: 04/May/14 08:25

Description

I've installed and configured zookeeper and kafka servers using apache quick start guide on ubuntu running in vmware.
Launch producer for already created topic "page_visits" and try to consume messages and nothing happens.
Trying to debug KafkaEndpoint i can see that server doesn't send me any key (KafkaConstants.KEY) so here:
message.setHeader(KafkaConstants.KEY, new String(mm.key()));
i got NPE and it silently fails.