Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-2855

Add kafka 0.9 support for Flume

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Duplicate
    • 1.7.0
    • None
    • Channel, Sinks+Sources
    • None
    • Add support for kafka 0.9.0.0 clients API

    Description

      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.

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            groghkov Grigoriy Rozhkov
            Votes:
            3 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Issue deployment