This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
from 602261648db [FLINK-32347][checkpoint] Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager. (#22793) add 149a5e34c1e [FLINNK-30859] Remove all Kafka connector code from main repo No new revisions were added by this update. Summary of changes: .../content.zh/docs/connectors/datastream/kafka.md | 659 ----- .../docs/connectors/table/upsert-kafka.md | 267 -- docs/content/docs/connectors/datastream/kafka.md | 752 ------ docs/content/docs/connectors/table/upsert-kafka.md | 300 --- docs/setup_docs.sh | 1 + .../5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 5 - .../7602816f-5c01-4b7a-9e3e-235dfedec245 | 2 +- .../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 | 3 +- .../f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e | 309 +-- .../flink-architecture-tests-production/pom.xml | 5 - flink-architecture-tests/pom.xml | 7 - .../8248e31e-b706-4471-bb65-4c927c65fccf | 0 .../97dda445-f6bc-43e2-8106-5876ca0cd052 | 78 - .../archunit-violations/stored.rules | 4 - flink-connectors/flink-connector-kafka/pom.xml | 338 --- .../apache/flink/connector/kafka/MetricUtil.java | 79 - .../kafka/sink/DefaultKafkaSinkContext.java | 79 - .../kafka/sink/FlinkKafkaInternalProducer.java | 375 --- .../connector/kafka/sink/KafkaCommittable.java | 104 - .../kafka/sink/KafkaCommittableSerializer.java | 57 - .../flink/connector/kafka/sink/KafkaCommitter.java | 146 -- .../kafka/sink/KafkaRecordSerializationSchema.java | 102 - .../KafkaRecordSerializationSchemaBuilder.java | 336 --- .../kafka/sink/KafkaSerializerWrapper.java | 91 - .../flink/connector/kafka/sink/KafkaSink.java | 138 - .../connector/kafka/sink/KafkaSinkBuilder.java | 215 -- .../flink/connector/kafka/sink/KafkaWriter.java | 473 ---- .../connector/kafka/sink/KafkaWriterState.java | 60 - .../kafka/sink/KafkaWriterStateSerializer.java | 54 - .../flink/connector/kafka/sink/Recyclable.java | 49 - .../flink/connector/kafka/sink/TopicSelector.java | 31 - .../connector/kafka/sink/TransactionAborter.java | 131 - .../kafka/sink/TransactionalIdFactory.java | 41 - .../kafka/sink/TransactionsToAbortChecker.java | 95 - .../flink/connector/kafka/source/KafkaSource.java | 241 -- .../connector/kafka/source/KafkaSourceBuilder.java | 534 ---- .../connector/kafka/source/KafkaSourceOptions.java | 65 - .../source/enumerator/KafkaSourceEnumState.java | 39 - .../enumerator/KafkaSourceEnumStateSerializer.java | 124 - .../source/enumerator/KafkaSourceEnumerator.java | 634 ----- .../initializer/NoStoppingOffsetsInitializer.java | 52 - .../enumerator/initializer/OffsetsInitializer.java | 186 -- .../initializer/OffsetsInitializerValidator.java | 39 - .../ReaderHandledOffsetsInitializer.java | 83 - .../initializer/SpecifiedOffsetsInitializer.java | 108 - .../initializer/TimestampOffsetsInitializer.java | 76 - .../enumerator/subscriber/KafkaSubscriber.java | 67 - .../subscriber/KafkaSubscriberUtils.java | 50 - .../subscriber/PartitionSetSubscriber.java | 76 - .../enumerator/subscriber/TopicListSubscriber.java | 63 - .../subscriber/TopicPatternSubscriber.java | 65 - .../source/metrics/KafkaSourceReaderMetrics.java | 330 --- .../source/reader/KafkaPartitionSplitReader.java | 532 ---- .../kafka/source/reader/KafkaRecordEmitter.java | 81 - .../kafka/source/reader/KafkaSourceReader.java | 199 -- .../KafkaDeserializationSchemaWrapper.java | 65 - .../KafkaRecordDeserializationSchema.java | 129 - ...KafkaValueOnlyDeserializationSchemaWrapper.java | 58 - .../KafkaValueOnlyDeserializerWrapper.java | 106 - .../reader/fetcher/KafkaSourceFetcherManager.java | 112 - .../kafka/source/split/KafkaPartitionSplit.java | 152 -- .../split/KafkaPartitionSplitSerializer.java | 72 - .../source/split/KafkaPartitionSplitState.java | 56 - .../connectors/kafka/FlinkKafkaConsumer.java | 342 --- .../connectors/kafka/FlinkKafkaConsumerBase.java | 1227 --------- .../connectors/kafka/FlinkKafkaErrorCode.java | 27 - .../connectors/kafka/FlinkKafkaException.java | 44 - .../connectors/kafka/FlinkKafkaProducer.java | 1950 -------------- .../connectors/kafka/FlinkKafkaProducer011.java | 72 - .../connectors/kafka/FlinkKafkaProducerBase.java | 442 ---- .../connectors/kafka/KafkaContextAware.java | 55 - .../kafka/KafkaDeserializationSchema.java | 84 - .../connectors/kafka/KafkaSerializationSchema.java | 61 - .../connectors/kafka/config/BoundedMode.java | 49 - .../connectors/kafka/config/OffsetCommitMode.java | 42 - .../connectors/kafka/config/OffsetCommitModes.java | 52 - .../connectors/kafka/config/StartupMode.java | 62 - .../kafka/internals/AbstractFetcher.java | 611 ----- .../internals/AbstractPartitionDiscoverer.java | 256 -- .../kafka/internals/ClosableBlockingQueue.java | 500 ---- .../connectors/kafka/internals/ExceptionProxy.java | 123 - .../internals/FlinkKafkaInternalProducer.java | 421 --- .../connectors/kafka/internals/Handover.java | 212 -- .../kafka/internals/KafkaCommitCallback.java | 44 - .../kafka/internals/KafkaConsumerThread.java | 564 ---- .../KafkaDeserializationSchemaWrapper.java | 70 - .../connectors/kafka/internals/KafkaFetcher.java | 260 -- .../kafka/internals/KafkaPartitionDiscoverer.java | 114 - .../internals/KafkaSerializationSchemaWrapper.java | 112 - .../kafka/internals/KafkaShuffleFetcher.java | 305 --- .../kafka/internals/KafkaTopicPartition.java | 137 - .../internals/KafkaTopicPartitionAssigner.java | 61 - .../kafka/internals/KafkaTopicPartitionLeader.java | 107 - .../kafka/internals/KafkaTopicPartitionState.java | 132 - .../KafkaTopicPartitionStateSentinel.java | 62 - ...aTopicPartitionStateWithWatermarkGenerator.java | 99 - .../kafka/internals/KafkaTopicsDescriptor.java | 91 - .../internals/KeyedSerializationSchemaWrapper.java | 58 - .../SourceContextWatermarkOutputAdapter.java | 50 - .../kafka/internals/TransactionalIdsGenerator.java | 100 - .../metrics/KafkaConsumerMetricConstants.java | 56 - .../metrics/KafkaMetricMutableWrapper.java | 48 - .../internals/metrics/KafkaMetricWrapper.java | 42 - .../kafka/partitioner/FlinkFixedPartitioner.java | 93 - .../kafka/partitioner/FlinkKafkaPartitioner.java | 56 - .../kafka/shuffle/FlinkKafkaShuffle.java | 402 --- .../kafka/shuffle/FlinkKafkaShuffleConsumer.java | 93 - .../kafka/shuffle/FlinkKafkaShuffleProducer.java | 229 -- .../kafka/shuffle/StreamKafkaShuffleSink.java | 43 - .../table/DynamicKafkaDeserializationSchema.java | 273 -- .../DynamicKafkaRecordSerializationSchema.java | 177 -- .../kafka/table/KafkaConnectorOptions.java | 355 --- .../kafka/table/KafkaConnectorOptionsUtil.java | 697 ----- .../connectors/kafka/table/KafkaDynamicSink.java | 479 ---- .../connectors/kafka/table/KafkaDynamicSource.java | 678 ----- .../kafka/table/KafkaDynamicTableFactory.java | 449 ---- .../connectors/kafka/table/ReducingUpsertSink.java | 91 - .../kafka/table/ReducingUpsertWriter.java | 183 -- .../kafka/table/SinkBufferFlushMode.java | 80 - .../table/UpsertKafkaDynamicTableFactory.java | 406 --- .../JSONKeyValueDeserializationSchema.java | 89 - .../serialization/KeyedDeserializationSchema.java | 56 - .../serialization/KeyedSerializationSchema.java | 61 - ...TypeInformationKeyValueSerializationSchema.java | 205 -- .../org.apache.flink.table.factories.Factory | 17 - .../architecture/TestCodeArchitectureTest.java | 43 - .../sink/FlinkKafkaInternalProducerITCase.java | 156 -- .../kafka/sink/KafkaCommittableSerializerTest.java | 44 - .../connector/kafka/sink/KafkaCommitterTest.java | 124 - .../KafkaRecordSerializationSchemaBuilderTest.java | 355 --- .../connector/kafka/sink/KafkaSinkBuilderTest.java | 113 - .../connector/kafka/sink/KafkaSinkITCase.java | 691 ----- .../connector/kafka/sink/KafkaTransactionLog.java | 199 -- .../kafka/sink/KafkaTransactionLogITCase.java | 162 -- .../connector/kafka/sink/KafkaWriterITCase.java | 673 ----- .../kafka/sink/KafkaWriterStateSerializerTest.java | 42 - .../kafka/sink/TransactionIdFactoryTest.java | 35 - .../kafka/sink/TransactionToAbortCheckerTest.java | 75 - .../kafka/sink/testutils/KafkaDataReader.java | 69 - .../sink/testutils/KafkaSinkExternalContext.java | 264 -- .../testutils/KafkaSinkExternalContextFactory.java | 53 - .../kafka/source/KafkaSourceBuilderTest.java | 209 -- .../connector/kafka/source/KafkaSourceITCase.java | 532 ---- .../kafka/source/KafkaSourceLegacyITCase.java | 164 -- .../kafka/source/KafkaSourceTestUtils.java | 59 - .../source/enumerator/KafkaEnumeratorTest.java | 560 ---- .../KafkaSourceEnumStateSerializerTest.java | 108 - .../initializer/OffsetsInitializerTest.java | 170 -- .../enumerator/subscriber/KafkaSubscriberTest.java | 130 - .../metrics/KafkaSourceReaderMetricsTest.java | 159 -- .../reader/KafkaPartitionSplitReaderTest.java | 431 ---- .../kafka/source/reader/KafkaSourceReaderTest.java | 635 ----- .../KafkaRecordDeserializationSchemaTest.java | 193 -- .../split/KafkaPartitionSplitSerializerTest.java | 54 - .../kafka/testutils/KafkaPartitionDataWriter.java | 64 - .../testutils/KafkaSourceExternalContext.java | 245 -- .../KafkaSourceExternalContextFactory.java | 59 - .../kafka/testutils/KafkaSourceTestEnv.java | 270 -- .../flink/connector/kafka/testutils/KafkaUtil.java | 189 -- .../kafka/FlinkFixedPartitionerTest.java | 109 - .../kafka/FlinkKafkaConsumerBaseMigrationTest.java | 425 --- .../kafka/FlinkKafkaConsumerBaseTest.java | 1523 ----------- .../kafka/FlinkKafkaInternalProducerITCase.java | 261 -- .../kafka/FlinkKafkaProducerBaseTest.java | 482 ---- .../connectors/kafka/FlinkKafkaProducerITCase.java | 833 ------ .../FlinkKafkaProducerMigrationOperatorTest.java | 58 - .../kafka/FlinkKafkaProducerMigrationTest.java | 81 - .../FlinkKafkaProducerStateSerializerTest.java | 148 -- .../connectors/kafka/FlinkKafkaProducerTest.java | 164 -- .../JSONKeyValueDeserializationSchemaTest.java | 130 - .../connectors/kafka/KafkaConsumerTestBase.java | 2728 -------------------- .../streaming/connectors/kafka/KafkaITCase.java | 380 --- .../connectors/kafka/KafkaMigrationTestBase.java | 158 -- .../kafka/KafkaProducerAtLeastOnceITCase.java | 43 - .../kafka/KafkaProducerExactlyOnceITCase.java | 38 - .../connectors/kafka/KafkaProducerTestBase.java | 401 --- .../kafka/KafkaSerializerUpgradeTest.java | 172 -- .../kafka/KafkaShortRetentionTestBase.java | 229 -- .../streaming/connectors/kafka/KafkaTestBase.java | 341 --- .../connectors/kafka/KafkaTestBaseWithFlink.java | 41 - .../connectors/kafka/KafkaTestEnvironment.java | 222 -- .../connectors/kafka/KafkaTestEnvironmentImpl.java | 497 ---- .../NextTransactionalIdHintSerializerTest.java | 56 - .../kafka/internals/AbstractFetcherTest.java | 279 -- .../internals/AbstractFetcherWatermarksTest.java | 499 ---- .../internals/AbstractPartitionDiscovererTest.java | 561 ---- .../kafka/internals/ClosableBlockingQueueTest.java | 616 ----- .../kafka/internals/KafkaTopicPartitionTest.java | 57 - .../kafka/internals/KafkaTopicsDescriptorTest.java | 66 - .../metrics/KafkaMetricMutableWrapperTest.java | 99 - .../shuffle/KafkaShuffleExactlyOnceITCase.java | 218 -- .../kafka/shuffle/KafkaShuffleITCase.java | 547 ---- .../kafka/shuffle/KafkaShuffleTestBase.java | 313 --- .../kafka/table/KafkaChangelogTableITCase.java | 484 ---- .../kafka/table/KafkaConnectorOptionsUtilTest.java | 138 - .../kafka/table/KafkaDynamicTableFactoryTest.java | 1340 ---------- .../connectors/kafka/table/KafkaTableITCase.java | 1169 --------- .../connectors/kafka/table/KafkaTableTestBase.java | 238 -- .../kafka/table/KafkaTableTestUtils.java | 110 - .../kafka/table/ReducingUpsertWriterTest.java | 385 --- .../table/UpsertKafkaDynamicTableFactoryTest.java | 666 ----- .../kafka/table/UpsertKafkaTableITCase.java | 882 ------- .../kafka/testutils/ClusterCommunicationUtils.java | 53 - .../connectors/kafka/testutils/DataGenerators.java | 244 -- .../kafka/testutils/FailingIdentityMapper.java | 129 - .../testutils/FakeStandardProducerConfig.java | 35 - .../connectors/kafka/testutils/IntegerSource.java | 133 - .../kafka/testutils/PartitionValidatingMapper.java | 57 - .../kafka/testutils/TestPartitionDiscoverer.java | 138 - .../kafka/testutils/TestSourceContext.java | 85 - .../kafka/testutils/ThrottledMapper.java | 43 - .../kafka/testutils/Tuple2FlinkPartitioner.java | 50 - .../kafka/testutils/ValidatingExactlyOnceSink.java | 146 -- .../src/test/resources/archunit.properties | 31 - .../src/test/resources/canal-data.txt | 11 - .../serializer-snapshot | Bin 126 -> 0 bytes .../context-state-serializer-1.11/test-data | Bin 19 -> 0 bytes .../serializer-snapshot | Bin 126 -> 0 bytes .../context-state-serializer-1.12/test-data | Bin 19 -> 0 bytes .../serializer-snapshot | Bin 126 -> 0 bytes .../context-state-serializer-1.13/test-data | Bin 19 -> 0 bytes .../serializer-snapshot | Bin 126 -> 0 bytes .../context-state-serializer-1.14/test-data | Bin 19 -> 0 bytes .../serializer-snapshot | Bin 126 -> 0 bytes .../context-state-serializer-1.15/test-data | Bin 19 -> 0 bytes .../serializer-snapshot | Bin 126 -> 0 bytes .../context-state-serializer-1.16/test-data | Bin 19 -> 0 bytes .../serializer-snapshot | Bin 126 -> 0 bytes .../context-state-serializer-1.17/test-data | Bin 19 -> 0 bytes .../resources/debezium-data-schema-exclude.txt | 16 - ...11-migration-kafka-producer-flink-1.10-snapshot | Bin 2032 -> 0 bytes ...11-migration-kafka-producer-flink-1.11-snapshot | Bin 2040 -> 0 bytes ....11-migration-kafka-producer-flink-1.8-snapshot | Bin 2032 -> 0 bytes ....11-migration-kafka-producer-flink-1.9-snapshot | Bin 2032 -> 0 bytes ...r-migration-test-flink1.10-empty-state-snapshot | Bin 1330 -> 0 bytes ...afka-consumer-migration-test-flink1.10-snapshot | Bin 1384 -> 0 bytes ...r-migration-test-flink1.11-empty-state-snapshot | Bin 1151 -> 0 bytes ...afka-consumer-migration-test-flink1.11-snapshot | Bin 1205 -> 0 bytes ...r-migration-test-flink1.12-empty-state-snapshot | Bin 1465 -> 0 bytes ...afka-consumer-migration-test-flink1.12-snapshot | Bin 1519 -> 0 bytes ...r-migration-test-flink1.13-empty-state-snapshot | Bin 1465 -> 0 bytes ...afka-consumer-migration-test-flink1.13-snapshot | Bin 1519 -> 0 bytes ...r-migration-test-flink1.14-empty-state-snapshot | Bin 1465 -> 0 bytes ...afka-consumer-migration-test-flink1.14-snapshot | Bin 1519 -> 0 bytes ...r-migration-test-flink1.15-empty-state-snapshot | Bin 1465 -> 0 bytes ...afka-consumer-migration-test-flink1.15-snapshot | Bin 1519 -> 0 bytes ...r-migration-test-flink1.16-empty-state-snapshot | Bin 1465 -> 0 bytes ...afka-consumer-migration-test-flink1.16-snapshot | Bin 1519 -> 0 bytes ...r-migration-test-flink1.17-empty-state-snapshot | Bin 1465 -> 0 bytes ...afka-consumer-migration-test-flink1.17-snapshot | Bin 1519 -> 0 bytes ...er-migration-test-flink1.8-empty-state-snapshot | Bin 1330 -> 0 bytes ...kafka-consumer-migration-test-flink1.8-snapshot | Bin 1384 -> 0 bytes ...er-migration-test-flink1.9-empty-state-snapshot | Bin 1330 -> 0 bytes ...kafka-consumer-migration-test-flink1.9-snapshot | Bin 1384 -> 0 bytes ...ka-migration-kafka-producer-flink-1.10-snapshot | Bin 1232 -> 0 bytes ...ka-migration-kafka-producer-flink-1.11-snapshot | Bin 1240 -> 0 bytes ...ka-migration-kafka-producer-flink-1.12-snapshot | Bin 1240 -> 0 bytes ...ka-migration-kafka-producer-flink-1.13-snapshot | Bin 1240 -> 0 bytes ...ka-migration-kafka-producer-flink-1.14-snapshot | Bin 1241 -> 0 bytes ...ka-migration-kafka-producer-flink-1.15-snapshot | Bin 1242 -> 0 bytes ...ka-migration-kafka-producer-flink-1.16-snapshot | Bin 1242 -> 0 bytes ...ka-migration-kafka-producer-flink-1.17-snapshot | Bin 1242 -> 0 bytes ...fka-migration-kafka-producer-flink-1.8-snapshot | Bin 1232 -> 0 bytes ...fka-migration-kafka-producer-flink-1.9-snapshot | Bin 1232 -> 0 bytes .../src/test/resources/log4j2-test.properties | 41 - .../src/test/resources/maxwell-data.txt | 20 - .../src/test/resources/product_changelog.txt | 7 - .../serializer-snapshot | Bin 134 -> 0 bytes .../transaction-state-serializer-1.11/test-data | Bin 17 -> 0 bytes .../serializer-snapshot | Bin 134 -> 0 bytes .../transaction-state-serializer-1.12/test-data | Bin 17 -> 0 bytes .../serializer-snapshot | Bin 134 -> 0 bytes .../transaction-state-serializer-1.13/test-data | Bin 17 -> 0 bytes .../serializer-snapshot | Bin 134 -> 0 bytes .../transaction-state-serializer-1.14/test-data | Bin 17 -> 0 bytes .../serializer-snapshot | Bin 134 -> 0 bytes .../transaction-state-serializer-1.15/test-data | Bin 17 -> 0 bytes .../serializer-snapshot | Bin 134 -> 0 bytes .../transaction-state-serializer-1.16/test-data | Bin 17 -> 0 bytes .../serializer-snapshot | Bin 134 -> 0 bytes .../transaction-state-serializer-1.17/test-data | Bin 17 -> 0 bytes flink-connectors/flink-sql-connector-kafka/pom.xml | 102 - .../src/main/resources/META-INF/NOTICE | 9 - .../flink/connectors/kafka/PackagingITCase.java | 40 - flink-connectors/pom.xml | 2 - .../flink-confluent-schema-registry/pom.xml | 2 +- .../flink-end-to-end-tests-common-kafka/pom.xml | 247 -- .../tests/util/kafka/KafkaContainerClient.java | 147 -- .../flink/tests/util/kafka/KafkaResource.java | 131 - .../tests/util/kafka/KafkaResourceFactory.java | 36 - .../util/kafka/LocalStandaloneKafkaResource.java | 452 ---- .../kafka/LocalStandaloneKafkaResourceFactory.java | 48 - .../flink/tests/util/kafka/KafkaSinkE2ECase.java | 83 - .../flink/tests/util/kafka/KafkaSourceE2ECase.java | 84 - .../tests/util/kafka/SQLClientKafkaITCase.java | 235 -- .../util/kafka/SQLClientSchemaRegistryITCase.java | 260 -- .../flink/tests/util/kafka/SmokeKafkaITCase.java | 189 -- .../kafka/containers/SchemaRegistryContainer.java | 51 - .../src/test/resources/kafka_e2e.sql | 75 - .../src/test/resources/log4j2-test.properties | 34 - .../flink-sql-client-test/pom.xml | 4 +- .../flink-streaming-kafka-test-base/pom.xml | 43 - .../kafka/test/base/CustomWatermarkExtractor.java | 53 - .../streaming/kafka/test/base/KafkaEvent.java | 74 - .../kafka/test/base/KafkaEventSchema.java | 54 - .../kafka/test/base/KafkaExampleUtil.java | 52 - .../kafka/test/base/RollingAdditionMapper.java | 55 - .../flink-streaming-kafka-test/pom.xml | 87 - .../flink/streaming/kafka/test/KafkaExample.java | 80 - flink-end-to-end-tests/pom.xml | 3 - flink-examples/flink-examples-streaming/pom.xml | 2 +- flink-python/pom.xml | 2 +- .../src/main/resources/archetype-resources/pom.xml | 2 +- .../src/main/resources/archetype-resources/pom.xml | 2 +- pom.xml | 1 - tools/ci/stage.sh | 2 - tools/maven/suppressions.xml | 2 +- 317 files changed, 12 insertions(+), 53624 deletions(-) delete mode 100644 docs/content.zh/docs/connectors/datastream/kafka.md delete mode 100644 docs/content.zh/docs/connectors/table/upsert-kafka.md delete mode 100644 docs/content/docs/connectors/datastream/kafka.md delete mode 100644 docs/content/docs/connectors/table/upsert-kafka.md delete mode 100644 flink-connectors/flink-connector-kafka/archunit-violations/8248e31e-b706-4471-bb65-4c927c65fccf delete mode 100644 flink-connectors/flink-connector-kafka/archunit-violations/97dda445-f6bc-43e2-8106-5876ca0cd052 delete mode 100644 flink-connectors/flink-connector-kafka/archunit-violations/stored.rules delete mode 100644 flink-connectors/flink-connector-kafka/pom.xml delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/MetricUtil.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/DefaultKafkaSinkContext.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittableSerializer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/Recyclable.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TopicSelector.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionAborter.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionalIdFactory.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionsToAbortChecker.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/NoStoppingOffsetsInitializer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializerValidator.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/ReaderHandledOffsetsInitializer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/PartitionSetSubscriber.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaRecordEmitter.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaDeserializationSchemaWrapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchema.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializationSchemaWrapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializerWrapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplit.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitSerializer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitState.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaErrorCode.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaException.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaContextAware.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaDeserializationSchema.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializationSchema.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/BoundedMode.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/OffsetCommitMode.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/OffsetCommitModes.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/StartupMode.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ExceptionProxy.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Handover.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaCommitCallback.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaConsumerThread.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaDeserializationSchemaWrapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaFetcher.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaPartitionDiscoverer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaSerializationSchemaWrapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaShuffleFetcher.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionAssigner.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionLeader.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionState.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateSentinel.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateWithWatermarkGenerator.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicsDescriptor.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KeyedSerializationSchemaWrapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SourceContextWatermarkOutputAdapter.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/TransactionalIdsGenerator.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaConsumerMetricConstants.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricMutableWrapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricWrapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkKafkaPartitioner.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/StreamKafkaShuffleSink.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/KeyedDeserializationSchema.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/KeyedSerializationSchema.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationKeyValueSerializationSchema.java delete mode 100644 flink-connectors/flink-connector-kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducerITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaCommittableSerializerTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaCommitterTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilderTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilderTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaTransactionLog.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaTransactionLogITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializerTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/TransactionIdFactoryTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/TransactionToAbortCheckerTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/testutils/KafkaDataReader.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/testutils/KafkaSinkExternalContext.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/testutils/KafkaSinkExternalContextFactory.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilderTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceLegacyITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceTestUtils.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaEnumeratorTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializerTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializerTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetricsTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReaderTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchemaTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitSerializerTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaPartitionDataWriter.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaSourceExternalContext.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaSourceExternalContextFactory.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaSourceTestEnv.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaUtil.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkFixedPartitionerTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaInternalProducerITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBaseTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationOperatorTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerStateSerializerTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/JSONKeyValueDeserializationSchemaTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaMigrationTestBase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerAtLeastOnceITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerExactlyOnceITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializerUpgradeTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetentionTestBase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBaseWithFlink.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironment.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/NextTransactionalIdHintSerializerTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherWatermarksTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscovererTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueueTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicsDescriptorTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricMutableWrapperTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/shuffle/KafkaShuffleExactlyOnceITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/shuffle/KafkaShuffleITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/shuffle/KafkaShuffleTestBase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaChangelogTableITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtilTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestBase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestUtils.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriterTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactoryTest.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/ClusterCommunicationUtils.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/DataGenerators.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/FailingIdentityMapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/FakeStandardProducerConfig.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/IntegerSource.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/PartitionValidatingMapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/TestPartitionDiscoverer.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/TestSourceContext.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/ThrottledMapper.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/Tuple2FlinkPartitioner.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/ValidatingExactlyOnceSink.java delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/archunit.properties delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/canal-data.txt delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.11/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.11/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.12/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.12/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.13/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.13/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.14/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.14/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.15/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.15/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.16/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.16/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.17/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.17/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/debezium-data-schema-exclude.txt delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink-1.10-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink-1.11-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink-1.8-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink-1.9-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.10-empty-state-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.10-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.11-empty-state-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.11-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.12-empty-state-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.12-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-empty-state-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.14-empty-state-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.14-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-empty-state-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.16-empty-state-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.16-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.17-empty-state-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.17-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.8-empty-state-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.8-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.9-empty-state-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.9-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.11-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.12-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.13-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.14-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.15-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.16-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.17-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.8-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.9-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/log4j2-test.properties delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/maxwell-data.txt delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/product_changelog.txt delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.11/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.11/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.12/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.12/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.13/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.13/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.14/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.14/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.15/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.15/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.16/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.16/test-data delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.17/serializer-snapshot delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.17/test-data delete mode 100644 flink-connectors/flink-sql-connector-kafka/pom.xml delete mode 100644 flink-connectors/flink-sql-connector-kafka/src/main/resources/META-INF/NOTICE delete mode 100644 flink-connectors/flink-sql-connector-kafka/src/test/java/org/apache/flink/connectors/kafka/PackagingITCase.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaContainerClient.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaResource.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaResourceFactory.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResourceFactory.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSinkE2ECase.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/KafkaSourceE2ECase.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientSchemaRegistryITCase.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SmokeKafkaITCase.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/containers/SchemaRegistryContainer.java delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/resources/kafka_e2e.sql delete mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/resources/log4j2-test.properties delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka-test-base/pom.xml delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka-test-base/src/main/java/org/apache/flink/streaming/kafka/test/base/CustomWatermarkExtractor.java delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka-test-base/src/main/java/org/apache/flink/streaming/kafka/test/base/KafkaEvent.java delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka-test-base/src/main/java/org/apache/flink/streaming/kafka/test/base/KafkaEventSchema.java delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka-test-base/src/main/java/org/apache/flink/streaming/kafka/test/base/KafkaExampleUtil.java delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka-test-base/src/main/java/org/apache/flink/streaming/kafka/test/base/RollingAdditionMapper.java delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka-test/pom.xml delete mode 100644 flink-end-to-end-tests/flink-streaming-kafka-test/src/main/java/org/apache/flink/streaming/kafka/test/KafkaExample.java