You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flume.apache.org by "Grigoriy Rozhkov (JIRA)" <ji...@apache.org> on 2015/12/14 12:59:46 UTC

[jira] [Created] (FLUME-2855) Add kafka 0.9 support for Flume

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)