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

Remove Kafka 0.10.x and 0.11.x connectors

    XMLWordPrintableJSON

Details

    • Hide
      In Flink 1.12 we removed the Kafka 0.10.x and 0.11.x connectors. Please use the universal Kafka connector which works with any Kafka cluster version after 0.10.2.x.

      Please refer to the documentation to learn about how to upgrade the Flink Kafka Connector version: https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/kafka.html.
      Show
      In Flink 1.12 we removed the Kafka 0.10.x and 0.11.x connectors. Please use the universal Kafka connector which works with any Kafka cluster version after 0.10.2.x. Please refer to the documentation to learn about how to upgrade the Flink Kafka Connector version: https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/kafka.html .

    Description

      Please see the ML thread for details: https://lists.apache.org/thread.html/r6d5c44e88d2d0fa187df6093694d6ad40c08561492c55b826b7231e7%40%3Cdev.flink.apache.org%3E

      In short, 0.10.x and 0.11.x are very old and you can use the "modern" Kafka connector to connect to older brokers/clusters. Plus, if push comes to shove, users can use the code from 1.11 and compile it against a newer Flink release.

      Attachments

        Issue Links

          Activity

            People

              aljoscha Aljoscha Krettek
              aljoscha Aljoscha Krettek
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: