Grigoriy Rozhkov created FLUME-2855:
---------------------------------------
Summary: Add kafka 0.9 support for Flume
Key: FLUME-2855
URL: https://issues.apache.org/jira/browse/FLUME-2855
Project: Flume
Issue Type: Improvement
Components: Channel, Sinks+Sources
Affects Versions: v1.7.0
Reporter: Grigoriy Rozhkov
Kafka 0.9 already released and it introduces new clients API that not
compatible with old one.
Add support for Apache Flume to use new kafka consumer and producer API. Old
classes will not be removed to save backward compatibility with old Kafka
Source, Sink and Channel implementations. User will not need to change agent
configuration if wants to use old Kafka. Kafka API version will able to be
configured in agent configuration file.
1. Add new Kafka Source implementation which uses new Kafka consumer API.
2. Add new Kafka Sink implementation which uses new Kafka producer API.
3. Add new Kafka Channel implementation.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
