Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2372

Update KafkaSink to use new Producer API

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.10.0
    • 0.10.0
    • Connectors / Kafka
    • None

    Description

      Flink's Kafka Sink is using Kafka's old Producer API, which is has very poor performance and a limited API.

      I'll implement a new KafkaSink which is using the new API.

      Attachments

        Activity

          People

            rmetzger Robert Metzger
            rmetzger Robert Metzger
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: