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

Reply via email to