This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
from a5505346 [hotfix] Apply spotless formatting
add 7e64c26e [FLINK-25538] Migrate tests from JUnit 4 to JUnit 5
add 1db38de2 [FLINK-25538] Replaces individual
@ExtendWith(TestLoggerExtension.class) annotations with global SPI registration
add 6f04b287 [FLINK-25538] Remove optional public modifiers from test
classes and methods following JUnit 5 best practices.
add 22d09e67 [FLINK-25538] Added ArchUnit rule (BanJunit4Rules) to prevent
future JUnit 4 usage
No new revisions were added by this update.
Summary of changes:
.../flink/tests/util/kafka/SmokeKafkaITCase.java | 3 -
.../86dfd459-67a9-4b26-9b5c-0b0bbf22681a | 48 ---------------
...c90862 => f902c3ff-48e5-424e-923f-3705c14930a0} | 0
.../archunit-violations/stored.rules | 10 +---
flink-connector-kafka/pom.xml | 5 --
.../architecture/TestCodeArchitectureTest.java | 3 +
.../flink/architecture/rules/BanJunit4Rules.java | 46 +++++++++++++++
.../dynamic/source/DynamicKafkaSourceITTest.java | 3 +-
.../kafka/sink/ExactlyOnceKafkaWriterITCase.java | 3 -
.../sink/FlinkKafkaInternalProducerITCase.java | 3 -
.../kafka/sink/KafkaCommittableSerializerTest.java | 8 +--
.../KafkaRecordSerializationSchemaBuilderTest.java | 45 +++++++-------
.../connector/kafka/sink/KafkaSinkBuilderTest.java | 3 +-
.../connector/kafka/sink/KafkaSinkITCase.java | 15 +++--
.../kafka/sink/KafkaTransactionLogITCase.java | 3 -
.../sink/KafkaWriterFaultToleranceITCase.java | 3 -
.../connector/kafka/sink/KafkaWriterITCase.java | 3 -
.../kafka/sink/KafkaWriterStateSerializerTest.java | 7 +--
.../kafka/sink/TransactionIdFactoryTest.java | 7 +--
.../kafka/sink/internal/KafkaCommitterTest.java | 3 -
.../sink/internal/TransactionIdFactoryTest.java | 12 ++--
.../kafka/source/KafkaSourceBuilderTest.java | 3 -
.../kafka/source/KafkaSourceMigrationITCase.java | 3 +-
.../KafkaSourceEnumStateSerializerTest.java | 8 +--
.../initializer/OffsetsInitializerTest.java | 35 ++++++-----
.../enumerator/subscriber/KafkaSubscriberTest.java | 22 +++----
.../metrics/KafkaSourceReaderMetricsTest.java | 12 ++--
.../KafkaRecordDeserializationSchemaTest.java | 20 +++----
.../kafka/testutils/TestKafkaContainer.java | 29 +--------
.../kafka/FlinkFixedPartitionerTest.java | 10 ++--
.../JSONKeyValueDeserializationSchemaTest.java | 12 ++--
.../streaming/connectors/kafka/KafkaTestBase.java | 21 ++++---
.../connectors/kafka/KafkaTestBaseWithFlink.java | 4 +-
.../metrics/KafkaMetricMutableWrapperTest.java | 3 -
.../DynamicKafkaRecordSerializationSchemaTest.java | 7 +--
.../kafka/table/DynamicKafkaTableFactoryTest.java | 8 +--
.../kafka/table/KafkaConnectorOptionsUtilTest.java | 14 ++---
.../kafka/table/KafkaDynamicTableFactoryTest.java | 69 +++++++++++-----------
.../kafka/table/ReducingUpsertWriterTest.java | 57 +++++++++---------
.../kafka/table/TableDataTypeUtilsTest.java | 13 ++--
.../table/UpsertKafkaDynamicTableFactoryTest.java | 51 ++++++++--------
.../org.junit.jupiter.api.extension.Extension | 1 +
pom.xml | 7 ---
43 files changed, 281 insertions(+), 361 deletions(-)
copy
flink-connector-kafka/archunit-violations/{27a0a5e4-29c2-4069-b381-952746c90862
=> f902c3ff-48e5-424e-923f-3705c14930a0} (100%)
create mode 100644
flink-connector-kafka/src/test/java/org/apache/flink/architecture/rules/BanJunit4Rules.java
create mode 100644
flink-connector-kafka/src/test/resources/META-INF/services/org.junit.jupiter.api.extension.Extension
