[FLUME-2578] Kafka source throws NPE if Kafka record has null key

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.6.0
• Assignee: Gwen Shapira
• Reporter: Gwen Shapira
• Created: 21/Dec/14 00:24
• Updated: 17/Apr/15 00:19
• Resolved: 30/Dec/14 19:44

Description

When the Kafka topics contain messages with no key (such as the messages sent by default from kafka-console-producer), Kafka Source throws NPE:

2014-12-20 12:58:59,604 ERROR
org.apache.flume.source.kafka.KafkaSource: KafkaSource EXCEPTION, {}
java.lang.NullPointerException
at java.lang.String.<init>(String.java:556)
at org.apache.flume.source.kafka.KafkaSource.process(KafkaSource.java:105)
at org.apache.flume.source.PollableSourceRunner$PollingRunner.run(PollableSourceRunner.java:139)
at java.lang.Thread.run(Thread.java:745)
)