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
