[jira] [Assigned] (FLUME-2915) The kafka channel using new APIs will be stuck when the sink is avro sink

["Jeff Holoman (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLUME-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jeff Holoman reassigned FLUME-2915:
-----------------------------------

    Assignee: Jeff Holoman

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