[ 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)