[FLUME-2667] Add new Kafka Java API in flume-ng-kafka-sink which keep compatibility with current API

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Duplicate
• Affects Version/s: 1.6.0
• Fix Version/s: notrack
• Component/s: Sinks+Sources
• Flags: Patch
• Assignee: Frank Yao
• Reporter: Frank Yao
• Created: 13/Apr/15 04:15
• Updated: 20/May/16 15:30
• Resolved: 20/May/16 15:30

Description

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.

Issue Links

• duplicates: FLUME-2820 Support New Kafka APIs