(flink-connector-kafka) branch main updated: [FLINK-40618][tests] Run SourceTopicIntegrity test in the integration-test phase

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

MartijnVisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git


The following commit(s) were added to refs/heads/main by this push:
     new beb52b43 [FLINK-40618][tests] Run SourceTopicIntegrity test in the 
integration-test phase
beb52b43 is described below

commit beb52b437bb1b049dce7049724084ed21e73926a
Author: Purushottam Sinha <psi...@confluent.io>
AuthorDate: Wed Sep 9 19:47:54 2026 +0530

    [FLINK-40618][tests] Run SourceTopicIntegrity test in the integration-test 
phase
    
    Rename SourceTopicIntegrityTest to SourceTopicIntegrityITCase so it is
    picked up by the integration-test surefire execution (forkCount=2, larger
    heap, reuseForks=false) instead of the unit-test execution (forkCount=4).
    
    The test starts a Testcontainers Kafka cluster and a 3-TaskManager
    MiniCluster and drives savepoint/restore -- heavyweight work that the
    *Test suffix wrongly routed into the unit-test phase. Its heavyweight
    siblings KafkaSourceITCase and KafkaSourceMigrationITCase are already
    named *ITCase. This is a test-classification cleanup: it reduces the
    number of concurrent Testcontainers-Kafka + MiniCluster forks and gives
    the test more heap and a fresh JVM per class.
    
    Generated-by: Claude Code (claude-opus-4-8)
---
 ...TopicIntegrityTest.java => SourceTopicIntegrityITCase.java} | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/SourceTopicIntegrityTest.java
 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/SourceTopicIntegrityITCase.java
similarity index 98%
rename from 
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/SourceTopicIntegrityTest.java
rename to 
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/SourceTopicIntegrityITCase.java
index bd474246..f50a5937 100644
--- 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/SourceTopicIntegrityTest.java
+++ 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/SourceTopicIntegrityITCase.java
@@ -60,11 +60,11 @@ import java.util.stream.Stream;
 
 /** Integration tests for topic integrity checking in KafkaSource. */
 @ResourceLock("KafkaTestBase")
-public class SourceTopicIntegrityTest {
-    private static final Logger LOG = 
LoggerFactory.getLogger(SourceTopicIntegrityTest.class);
-    private static final String SOURCE_TOPIC_NAME = 
"SourceTopicIntegrityTest_source-topic";
-    private static final String SOURCE_TOPIC_PATTERN = 
"SourceTopicIntegrityTest_source.*";
-    private static final String SINK_TOPIC_NAME = 
"SourceTopicIntegrityTest_sink-topic";
+public class SourceTopicIntegrityITCase {
+    private static final Logger LOG = 
LoggerFactory.getLogger(SourceTopicIntegrityITCase.class);
+    private static final String SOURCE_TOPIC_NAME = 
"SourceTopicIntegrityITCase_source-topic";
+    private static final String SOURCE_TOPIC_PATTERN = 
"SourceTopicIntegrityITCase_source.*";
+    private static final String SINK_TOPIC_NAME = 
"SourceTopicIntegrityITCase_sink-topic";
     private static final long DISCOVERY_INTERVAL = 50L;
     private static final Duration ERROR_DISCOVERY_TIMEOUT = 
Duration.ofSeconds(20);
     @TempDir private Path savepointBasePath;