[
https://issues.apache.org/jira/browse/FLUME-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grant Henke resolved FLUME-2667.
--------------------------------
Resolution: Duplicate
Fix Version/s: notrack
> Add new Kafka Java API in flume-ng-kafka-sink which keep compatibility with
> current API
> ---------------------------------------------------------------------------------------
>
> Key: FLUME-2667
> URL: https://issues.apache.org/jira/browse/FLUME-2667
> Project: Flume
> Issue Type: Improvement
> Components: Sinks+Sources
> Affects Versions: v1.6.0
> Reporter: Frank Yao
> Assignee: Frank Yao
> Priority: Minor
> Fix For: notrack
>
> Attachments: FLUME-2667-0.patch
>
>
> Kafka has released 0.8.2 and meanwhile starts to using new producer API which
> is written in Java originally. Currently, we use javaapi written in scala in
> flume-ng-kafka-sink. I've added new Java API into current sink and re-write
> the tests with mockito.
> As far as I know by reading the source code of kafka 0.8.2, new Java API of
> Consumer would seen be released soon. I think in the very soon, kafka API
> will all change into Java API.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
