This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new f1f0d97c692 MINOR: remove un-necessary integration tags (#22095)
f1f0d97c692 is described below
commit f1f0d97c6928206acde976c9d222a3ffc30e411a
Author: Maros Orsak <[email protected]>
AuthorDate: Mon Apr 20 10:33:24 2026 +0200
MINOR: remove un-necessary integration tags (#22095)
This removes un-necessary integration tags from the test suites.
Reviewers: Chia-Ping Tsai <[email protected]>
---
.../connect/mirror/integration/IdentityReplicationIntegrationTest.java | 2 --
.../mirror/integration/MirrorConnectorsIntegrationExactlyOnceTest.java | 2 --
.../connect/mirror/integration/MirrorConnectorsIntegrationSSLTest.java | 2 --
.../MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java | 2 --
.../test/java/org/apache/kafka/tools/AbstractResetIntegrationTest.java | 2 ++
tools/src/test/java/org/apache/kafka/tools/ResetIntegrationTest.java | 2 --
.../test/java/org/apache/kafka/tools/ResetIntegrationWithSslTest.java | 2 --
7 files changed, 2 insertions(+), 12 deletions(-)
diff --git
a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/IdentityReplicationIntegrationTest.java
b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/IdentityReplicationIntegrationTest.java
index 1d4339f3977..bc5be9efcfd 100644
---
a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/IdentityReplicationIntegrationTest.java
+++
b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/IdentityReplicationIntegrationTest.java
@@ -19,7 +19,6 @@ package org.apache.kafka.connect.mirror.integration;
import org.apache.kafka.connect.mirror.IdentityReplicationPolicy;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
import java.util.Map;
@@ -31,7 +30,6 @@ import java.util.Map;
* migrated from the primary cluster to the backup cluster. Tests validate
that consumer offsets
* are translated and replicated from the primary cluster to the backup
cluster during this failover.
*/
-@Tag("integration")
public class IdentityReplicationIntegrationTest extends
MirrorConnectorsIntegrationBaseTest {
@BeforeEach
public void startClusters() throws Exception {
diff --git
a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationExactlyOnceTest.java
b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationExactlyOnceTest.java
index 5578c2b2877..c7504658736 100644
---
a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationExactlyOnceTest.java
+++
b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationExactlyOnceTest.java
@@ -21,7 +21,6 @@ import org.apache.kafka.connect.mirror.MirrorSourceConnector;
import org.apache.kafka.connect.runtime.distributed.DistributedConfig;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
import java.util.List;
@@ -32,7 +31,6 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
/**
* Tests MM2 replication with exactly-once support enabled on the Connect
clusters.
*/
-@Tag("integration")
public class MirrorConnectorsIntegrationExactlyOnceTest extends
MirrorConnectorsIntegrationBaseTest {
@BeforeEach
diff --git
a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationSSLTest.java
b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationSSLTest.java
index 96a71710d0d..afebb626e9d 100644
---
a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationSSLTest.java
+++
b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationSSLTest.java
@@ -25,7 +25,6 @@ import org.apache.kafka.test.TestSslUtils;
import org.apache.kafka.test.TestUtils;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
import java.util.Map;
import java.util.Properties;
@@ -34,7 +33,6 @@ import java.util.stream.Collectors;
/**
* Tests MM2 replication with SSL enabled at backup kafka cluster
*/
-@Tag("integration")
public class MirrorConnectorsIntegrationSSLTest extends
MirrorConnectorsIntegrationBaseTest {
@BeforeEach
diff --git
a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java
b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java
index d376fa8f2da..0d189b5c4d1 100644
---
a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java
+++
b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsWithCustomForwardingAdminIntegrationTest.java
@@ -40,7 +40,6 @@ import org.apache.kafka.server.config.ServerConfigs;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
import java.util.Collection;
@@ -62,7 +61,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
/**
* Tests MM2 is using provided ForwardingAdmin to create/alter topics,
partitions and ACLs.
*/
-@Tag("integration")
public class MirrorConnectorsWithCustomForwardingAdminIntegrationTest extends
MirrorConnectorsIntegrationBaseTest {
private static final int TOPIC_ACL_SYNC_DURATION_MS = 30_000;
diff --git
a/tools/src/test/java/org/apache/kafka/tools/AbstractResetIntegrationTest.java
b/tools/src/test/java/org/apache/kafka/tools/AbstractResetIntegrationTest.java
index 57c4a5e8bcb..8c7d0c55105 100644
---
a/tools/src/test/java/org/apache/kafka/tools/AbstractResetIntegrationTest.java
+++
b/tools/src/test/java/org/apache/kafka/tools/AbstractResetIntegrationTest.java
@@ -43,6 +43,7 @@ import org.apache.kafka.streams.kstream.Produced;
import org.apache.kafka.streams.kstream.TimeWindows;
import org.apache.kafka.test.TestUtils;
+import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;
import org.junit.jupiter.api.Timeout;
@@ -63,6 +64,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
@Timeout(600)
+@Tag("integration")
public abstract class AbstractResetIntegrationTest {
static EmbeddedKafkaCluster cluster;
diff --git
a/tools/src/test/java/org/apache/kafka/tools/ResetIntegrationTest.java
b/tools/src/test/java/org/apache/kafka/tools/ResetIntegrationTest.java
index f11578e2314..e403bb9b880 100644
--- a/tools/src/test/java/org/apache/kafka/tools/ResetIntegrationTest.java
+++ b/tools/src/test/java/org/apache/kafka/tools/ResetIntegrationTest.java
@@ -33,7 +33,6 @@ import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;
import org.junit.jupiter.api.Timeout;
@@ -61,7 +60,6 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
/**
* Tests local state store and global application cleanup.
*/
-@Tag("integration")
@Timeout(600)
public class ResetIntegrationTest extends AbstractResetIntegrationTest {
private static final String NON_EXISTING_TOPIC = "nonExistingTopic";
diff --git
a/tools/src/test/java/org/apache/kafka/tools/ResetIntegrationWithSslTest.java
b/tools/src/test/java/org/apache/kafka/tools/ResetIntegrationWithSslTest.java
index 9a072877eda..20b65f818bf 100644
---
a/tools/src/test/java/org/apache/kafka/tools/ResetIntegrationWithSslTest.java
+++
b/tools/src/test/java/org/apache/kafka/tools/ResetIntegrationWithSslTest.java
@@ -26,7 +26,6 @@ import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.TestInfo;
import java.io.IOException;
@@ -36,7 +35,6 @@ import java.util.Properties;
/**
* Tests command line SSL setup for reset tool.
*/
-@Tag("integration")
public class ResetIntegrationWithSslTest extends AbstractResetIntegrationTest {
public static final EmbeddedKafkaCluster CLUSTER;
