[
https://issues.apache.org/jira/browse/FLUME-2855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lior Zeno resolved FLUME-2855.
------------------------------
Resolution: Duplicate
> 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
> Attachments: FLUME-2821.patch
>
>
> 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)
