[FLINK-10843] Make Kafka version definition more flexible for new Kafka table factory

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.7.0
• Fix Version/s: 1.7.0
• Component/s: Connectors / Kafka, Table SQL / API
• Labels: pull-request-available
• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 09/Nov/18 13:51
• Updated: 16/Nov/18 15:59
• Resolved: 16/Nov/18 15:59

Description

Currently, a user has to specify a specific version for a Kafka connector like:

connector:
  type: kafka
  version: "0.11"     # required: valid connector versions are "0.8", "0.9", "0.10", and "0.11"
  topic: ...          # required: topic name from which the table is read

However, the new Kafka connector aims to be universal, thus, at least for 1.x and 2.x versions which we should support those as parameters as well. Currently, 2.0 is the only accepted string for the factory.

Issue Links

• is duplicated by: FLINK-10620 Remove the dependency on the version string literal.
• links to: GitHub Pull Request #7087