[FLINK-10872] [e2e] Extend SQL Client end-to-end to for Kafka 0.11 co…

…nnector

This closes apache#7100.

flink-end-to-end-tests/flink-sql-client-test/pom.xml

@@ -186,19 +186,18 @@ under the License.
  </artifactItem>
  <artifactItem>
  <groupId>org.apache.flink</groupId>
- <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
+ <artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId>
  <version>${project.version}</version>
  <classifier>sql-jar</classifier>
  <type>jar</type>
  </artifactItem>
- <!-- This SQL JAR is not used for now to avoid dependency conflicts; see FLINK-10107.
  <artifactItem>
  <groupId>org.apache.flink</groupId>
- <artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId>
+ <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
  <version>${project.version}</version>
  <classifier>sql-jar</classifier>
  <type>jar</type>
- </artifactItem>-->
+ </artifactItem>
  <artifactItem>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-connector-elasticsearch6_${scala.binary.version}</artifactId>

flink-end-to-end-tests/run-nightly-tests.sh

@@ -143,6 +143,7 @@ run_test "State TTL RocksDb backend end-to-end test" "$END_TO_END_DIR/test-scrip
 
 run_test "SQL Client end-to-end test" "$END_TO_END_DIR/test-scripts/test_sql_client.sh"
 run_test "SQL Client end-to-end test for Kafka 0.10" "$END_TO_END_DIR/test-scripts/test_sql_client_kafka010.sh"
+run_test "SQL Client end-to-end test for Kafka 0.11" "$END_TO_END_DIR/test-scripts/test_sql_client_kafka011.sh"
 run_test "SQL Client end-to-end test for modern Kafka" "$END_TO_END_DIR/test-scripts/test_sql_client_kafka.sh"
 
 run_test "Heavy deployment end-to-end test" "$END_TO_END_DIR/test-scripts/test_heavy_deployment.sh" "skip_check_exceptions"

flink-end-to-end-tests/test-scripts/test_sql_client_kafka011.sh

@@ -0,0 +1,22 @@
+#!/usr/bin/env bash
+################################################################################
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http:https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+################################################################################
+
+set -Eeuo pipefail
+
+source "$(dirname "$0")"/test_sql_client_kafka_common.sh 0.11 0.11.0.2 3.2.0 3.2 "kafka-0.11" "0.11"