[FLUME-2242] Flume Sink and Source for Apache Kafka

• Type: New Feature
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.4.0
• Fix Version/s: 1.6.0
• Component/s: Sinks+Sources
• Labels: kafka sink source

Environment

kafka, scala jar dependencies

• Assignee: Unassigned
• Reporter: Frank Yao
• Created: 21/Nov/13 02:53
• Updated: 17/Apr/15 01:21
• Resolved: 17/Sep/14 04:37

Description

Source and Sinks for LinkedIn Kafka 0.7.2. I use my code in our company and runs in 100k msg/sec.

My Project:https://github.com/baniuyao/flume-kafka

Sub-Tasks

• Add support for Kafka Source: Resolved
• Add support for Kafka Sink: Resolved