Julian Zhang created FLUME-2915:
-----------------------------------
Summary: The kafka channel using new APIs will be stuck when the
sink is avro sink
Key: FLUME-2915
URL: https://issues.apache.org/jira/browse/FLUME-2915
Project: Flume
Issue Type: Bug
Components: Channel
Affects Versions: v1.7.0
Reporter: Julian Zhang
The avro sink was stuck when I using the kafka channel which using the new APIs.
After couple of hours I found the issue at KafkaChannel.java#L384:
e.getHeaders().put(KEY_HEADER, record.key());
and change it to:
if (record.key() != null) {
e.getHeaders().put(KEY_HEADER, record.key());
}
The reason is:
record.key() could be null if the user didn't set it. And the avro serialize
the event will throw a NullPointerException.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
