This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit d7a2234b9b31668eb011315a3ef3fe1788240548 Author: yanghua <[email protected]> AuthorDate: Sat Oct 13 14:36:25 2018 +0800 [FLINK-9697] Add connector version value for kafka 2.0 --- .../main/java/org/apache/flink/table/descriptors/KafkaValidator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/KafkaValidator.java b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/KafkaValidator.java index cad37f8..c7ddb7f 100644 --- a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/KafkaValidator.java +++ b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/KafkaValidator.java @@ -36,6 +36,7 @@ public class KafkaValidator extends ConnectorDescriptorValidator { public static final String CONNECTOR_VERSION_VALUE_09 = "0.9"; public static final String CONNECTOR_VERSION_VALUE_010 = "0.10"; public static final String CONNECTOR_VERSION_VALUE_011 = "0.11"; + public static final String CONNECTOR_VERSION_VALUE_20 = "2.0"; public static final String CONNECTOR_TOPIC = "connector.topic"; public static final String CONNECTOR_STARTUP_MODE = "connector.startup-mode"; public static final String CONNECTOR_STARTUP_MODE_VALUE_EARLIEST = "earliest-offset"; @@ -73,7 +74,8 @@ public class KafkaValidator extends ConnectorDescriptorValidator { CONNECTOR_VERSION_VALUE_08, CONNECTOR_VERSION_VALUE_09, CONNECTOR_VERSION_VALUE_010, - CONNECTOR_VERSION_VALUE_011); + CONNECTOR_VERSION_VALUE_011, + CONNECTOR_VERSION_VALUE_20); properties.validateEnumValues(CONNECTOR_VERSION(), false, versions); properties.validateString(CONNECTOR_TOPIC, false, 1, Integer.MAX_VALUE); }
