[FLINK-33361][connectors/kafka] Add Java 17 compatibility to Flink Kafka connector

Author: snuyanzin

.github/workflows/push_pr.yml

@@ -26,10 +26,14 @@ jobs:
     strategy:
       matrix:
         flink: [ 1.17.1, 1.18.0 ]
+        jdk: [ 8, 11, 17 ]
+        exclude:
+          - jdk: 17
+            flink: 1.17.1
     uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
     with:
       flink_version: ${{ matrix.flink }}
-    
+      jdk_version: ${{ matrix.jdk }}
   python_test:
     strategy:
       matrix:

flink-connector-kafka/pom.xml

@@ -34,6 +34,14 @@ under the License.
 
     <packaging>jar</packaging>
 
+    <properties>
+        <flink.connector.module.config><!--
+        FlinkKafkaProducerBaseTest --> --add-opens=java.base/java.lang=ALL-UNNAMED <!--
+        FlinkKafkaProducerBaseTest --> --add-opens=java.base/java.util.concurrent.locks=ALL-UNNAMED <!--
+        FlinkKafkaConsumerBaseTest --> --add-opens=java.base/java.util=ALL-UNNAMED <!--
+        KafkaProducerExactlyOnceITCase --> --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED </flink.connector.module.config>
+    </properties>
+
     <dependencies>
 
         <!-- Core -->

pom.xml

@@ -78,6 +78,13 @@ under the License.
         <log4j.version>2.17.1</log4j.version>
 
         <flink.parent.artifactId>flink-connector-kafka-parent</flink.parent.artifactId>
+
+        <!-- This property should contain the add-opens/add-exports commands required for the tests
+         in the given connector's module to pass.
+         It MUST be a space-separated list not containing any newlines,
+         of entries in the form '[-]{2}add-[opens|exports]=<module>/<package>=ALL-UNNAMED'.-->
+        <flink.connector.module.config/>
+        <flink.surefire.baseArgLine>-XX:+UseG1GC -Xms256m -XX:+IgnoreUnrecognizedVMOptions ${flink.connector.module.config}</flink.surefire.baseArgLine>
     </properties>
 
     <dependencies>