[ https://issues.apache.org/jira/browse/FLUME-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jeff Holoman updated FLUME-2915: -------------------------------- Attachment: FLUME-2915.patch > 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 > Assignee: Jeff Holoman > Attachments: FLUME-2915.patch > > > 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)