4.0.0 io.confluent.flink flink-connector-kafka-parent 3.3.0-1.19-cp1 flink-connector-kafka Flink : Connectors : Kafka jar --add-opens=java.base/java.lang=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.locks=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED io.confluent.flink flink-streaming-java ${flink.version} provided io.confluent.flink flink-connector-base ${flink.version} provided io.confluent.flink flink-table-api-java-bridge ${flink.version} provided true org.apache.kafka kafka-clients ${kafka.version} com.google.guava guava org.hamcrest hamcrest-all ${hamcrest.version} test org.powermock powermock-module-junit4 ${powermock.version} jar test org.powermock powermock-api-mockito2 ${powermock.version} jar test org.mockito mockito-core io.confluent.flink flink-core ${flink.version} test test-jar io.confluent.flink flink-streaming-java ${flink.version} test test-jar org.testcontainers kafka test org.testcontainers junit-jupiter test org.yaml snakeyaml 2.2 test io.confluent.flink flink-test-utils ${flink.version} test io.confluent.flink flink-connector-test-utils ${flink.version} test io.confluent.flink flink-runtime ${flink.version} test-jar test io.confluent.flink flink-connector-base ${flink.version} test test-jar io.confluent.flink flink-metrics-jmx ${flink.version} test io.confluent.flink flink-table-common ${flink.version} test-jar test io.confluent.flink flink-table-test-utils ${flink.version} test io.confluent.flink flink-table-api-scala-bridge_${scala.binary.version} ${flink.version} test io.confluent.flink flink-table-planner_${scala.binary.version} ${flink.version} test-jar test io.confluent.flink flink-json ${flink.version} test io.confluent.flink flink-avro ${flink.version} test io.confluent.flink flink-avro-confluent-registry ${flink.version} test io.confluent.flink flink-csv ${flink.version} test io.confluent.flink flink-architecture-tests-test test org.apache.maven.plugins maven-jar-plugin test-jar **/KafkaTestEnvironment* **/testutils/* META-INF/LICENSE META-INF/NOTICE org.apache.maven.plugins maven-source-plugin attach-test-sources test-jar-no-fork false **/KafkaTestEnvironment* **/testutils/* META-INF/LICENSE META-INF/NOTICE