[FLUME-2820] Support New Kafka APIs

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.7.0
• Assignee: Jeff Holoman
• Reporter: Jeff Holoman
• Created: 22/Oct/15 13:24
• Updated: 18/Jun/16 17:24
• Resolved: 29/Mar/16 17:47

Description

Flume utilizes the older Kafka producer and consumer APIs. We should add implementations of the Source, Channel and Sink that utilize the new APIs.

Issue Links

• is depended upon by: FLUME-2852 Kafka Source/Sink should optionally read/write Flume records
• is duplicated by: FLUME-2792 Flume Kafka Kerberos Support
• is duplicated by: FLUME-2667 Add new Kafka Java API in flume-ng-kafka-sink which keep compatibility with current API

Sub-Tasks

• Flume-Kafka Source with new Consumer: Closed
• Flume-Kafka-Sink with new Producer: Closed
• Flume-Kafka-Channel with new APIs: Closed