This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new f55d45a51b9 [improve][ci] Move replication tests to new group Broker
Group 5 in Pulsar CI (#24917)
f55d45a51b9 is described below
commit f55d45a51b9862240f2139104c16533a29636240
Author: Lari Hotari <[email protected]>
AuthorDate: Wed Oct 29 19:46:03 2025 +0200
[improve][ci] Move replication tests to new group Broker Group 5 in Pulsar
CI (#24917)
---
.github/workflows/pulsar-ci.yaml | 2 ++
build/run_unit_group.sh | 6 +++++-
.../pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java | 1 +
.../org/apache/pulsar/broker/service/AbstractReplicatorTest.java | 2 +-
.../DisabledCreateTopicToRemoteClusterForReplicationTest.java | 2 +-
.../pulsar/broker/service/OneWayReplicatorDeduplicationTest.java | 2 +-
.../java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java | 2 +-
.../broker/service/OneWayReplicatorUsingGlobalPartitionedTest.java | 2 +-
.../pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java | 2 +-
.../java/org/apache/pulsar/broker/service/PeerReplicatorTest.java | 4 ++--
.../apache/pulsar/broker/service/ReplicatedSubscriptionTest.java | 2 +-
.../broker/service/ReplicatedSubscriptionWithTransactionTest.java | 2 +-
.../org/apache/pulsar/broker/service/ReplicationTopicGcTest.java | 2 +-
.../pulsar/broker/service/ReplicationTopicGcUsingGlobalZKTest.java | 2 +-
.../java/org/apache/pulsar/broker/service/ReplicationTxnTest.java | 2 +-
.../org/apache/pulsar/broker/service/ReplicatorAdminTlsTest.java | 2 +-
.../pulsar/broker/service/ReplicatorAdminTlsWithKeyStoreTest.java | 2 +-
.../org/apache/pulsar/broker/service/ReplicatorGlobalNSTest.java | 2 +-
.../org/apache/pulsar/broker/service/ReplicatorRateLimiterTest.java | 2 +-
.../apache/pulsar/broker/service/ReplicatorRemoveClusterTest.java | 2 +-
.../test/java/org/apache/pulsar/broker/service/ReplicatorTest.java | 2 +-
.../java/org/apache/pulsar/broker/service/ReplicatorTlsTest.java | 2 +-
.../apache/pulsar/broker/service/ReplicatorTopicPoliciesTest.java | 2 +-
.../broker/service/TransactionalReplicateSubscriptionTest.java | 1 +
.../service/persistent/PersistentReplicatorInflightTaskTest.java | 2 +-
25 files changed, 31 insertions(+), 23 deletions(-)
diff --git a/.github/workflows/pulsar-ci.yaml b/.github/workflows/pulsar-ci.yaml
index d8ddb7d51a0..5443f7e4bf5 100644
--- a/.github/workflows/pulsar-ci.yaml
+++ b/.github/workflows/pulsar-ci.yaml
@@ -318,6 +318,8 @@ jobs:
group: BROKER_GROUP_3
- name: Brokers - Broker Group 4
group: BROKER_GROUP_4
+ - name: Brokers - Broker Group 5
+ group: BROKER_GROUP_5
- name: Brokers - Client Api
group: BROKER_CLIENT_API
- name: Brokers - Client Impl
diff --git a/build/run_unit_group.sh b/build/run_unit_group.sh
index 1fc7a294153..9653a787325 100755
--- a/build/run_unit_group.sh
+++ b/build/run_unit_group.sh
@@ -82,7 +82,7 @@ function test_group_broker_group_1() {
}
function test_group_broker_group_2() {
- mvn_test -pl pulsar-broker
-Dgroups='schema,utils,functions-worker,broker-io,broker-discovery,broker-compaction,broker-naming,broker-replication,websocket,other'
+ mvn_test -pl pulsar-broker
-Dgroups='schema,utils,functions-worker,broker-io,broker-discovery,broker-compaction,broker-naming,websocket,other'
}
function test_group_broker_group_3() {
@@ -95,6 +95,10 @@ function test_group_broker_group_4() {
mvn_test -pl pulsar-broker -Dgroups='cluster-migration'
}
+function test_group_broker_group_5() {
+ mvn_test -pl pulsar-broker -Dgroups='broker-replication'
+}
+
function test_group_broker_client_api() {
mvn_test -pl pulsar-broker -Dgroups='broker-api'
}
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java
index 19859d17d50..0a2a74d9a22 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/SameAuthParamsLookupAutoClusterFailoverTest.java
@@ -42,6 +42,7 @@ import org.testng.annotations.AfterMethod;
import org.testng.annotations.DataProvider;
import org.testng.annotations.Test;
+@Test(groups = "broker-replication")
public class SameAuthParamsLookupAutoClusterFailoverTest extends
OneWayReplicatorTestBase {
public void setup() throws Exception {
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractReplicatorTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractReplicatorTest.java
index afb9cadd55f..39252ac0a94 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractReplicatorTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractReplicatorTest.java
@@ -51,7 +51,7 @@ import org.awaitility.reflect.WhiteboxImpl;
import org.testng.Assert;
import org.testng.annotations.Test;
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class AbstractReplicatorTest {
@Test
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DisabledCreateTopicToRemoteClusterForReplicationTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DisabledCreateTopicToRemoteClusterForReplicationTest.java
index ec9e8b6c270..3aa8fa6a7c4 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DisabledCreateTopicToRemoteClusterForReplicationTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/DisabledCreateTopicToRemoteClusterForReplicationTest.java
@@ -44,7 +44,7 @@ import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
@Slf4j
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class DisabledCreateTopicToRemoteClusterForReplicationTest extends
OneWayReplicatorTestBase {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java
index 93486c17330..353d2ab89e2 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java
@@ -91,7 +91,7 @@ import org.testng.annotations.DataProvider;
import org.testng.annotations.Test;
@Slf4j
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class OneWayReplicatorDeduplicationTest extends
OneWayReplicatorTestBase {
static final ObjectMapper JACKSON = new ObjectMapper();
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java
index de6c5f9f356..d7b8d71a5a4 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java
@@ -124,7 +124,7 @@ import org.testng.annotations.DataProvider;
import org.testng.annotations.Test;
@Slf4j
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class OneWayReplicatorTest extends OneWayReplicatorTestBase {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalPartitionedTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalPartitionedTest.java
index a0099f97fea..d862636f0b2 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalPartitionedTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalPartitionedTest.java
@@ -49,7 +49,7 @@ import org.testng.annotations.DataProvider;
import org.testng.annotations.Test;
@Slf4j
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class OneWayReplicatorUsingGlobalPartitionedTest extends
OneWayReplicatorTest {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java
index 7e20bdb8780..18f601d51b3 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java
@@ -52,7 +52,7 @@ import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
@Slf4j
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class OneWayReplicatorUsingGlobalZKTest extends OneWayReplicatorTest {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PeerReplicatorTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PeerReplicatorTest.java
index 9f655921794..8de6a7a448d 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PeerReplicatorTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PeerReplicatorTest.java
@@ -44,7 +44,7 @@ import org.testng.annotations.BeforeClass;
import org.testng.annotations.DataProvider;
import org.testng.annotations.Test;
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class PeerReplicatorTest extends ReplicatorTestBase {
@Override
@@ -187,7 +187,7 @@ public class PeerReplicatorTest extends ReplicatorTestBase {
*
* @throws Exception
*/
- @Test(groups = "broker")
+ @Test
public void testPeerClusterInReplicationClusterListChange() throws
Exception {
// clean up peer-clusters
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatedSubscriptionTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatedSubscriptionTest.java
index a34b8817ca5..45026ce61bf 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatedSubscriptionTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatedSubscriptionTest.java
@@ -82,7 +82,7 @@ import org.testng.annotations.Test;
/**
* Tests replicated subscriptions (PIP-33).
*/
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicatedSubscriptionTest extends ReplicatorTestBase {
private static final Logger log =
LoggerFactory.getLogger(ReplicatedSubscriptionTest.class);
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatedSubscriptionWithTransactionTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatedSubscriptionWithTransactionTest.java
index 444d40d08b0..bc50f1fc9f3 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatedSubscriptionWithTransactionTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatedSubscriptionWithTransactionTest.java
@@ -26,7 +26,7 @@ import org.testng.annotations.Test;
/**
* Tests replicated subscriptions with transaction (PIP-33).
*/
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicatedSubscriptionWithTransactionTest extends
ReplicatedSubscriptionTest {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcTest.java
index 91c667d1d78..c2b6d4281a9 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcTest.java
@@ -45,7 +45,7 @@ import org.testng.annotations.DataProvider;
import org.testng.annotations.Test;
@Slf4j
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicationTopicGcTest extends OneWayReplicatorTestBase {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcUsingGlobalZKTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcUsingGlobalZKTest.java
index ce6eddc5698..fabfb3333e9 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcUsingGlobalZKTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcUsingGlobalZKTest.java
@@ -25,7 +25,7 @@ import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
@Slf4j
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicationTopicGcUsingGlobalZKTest extends
ReplicationTopicGcTest {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTxnTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTxnTest.java
index bd4a0889c73..1eb59c725f8 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTxnTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTxnTest.java
@@ -59,7 +59,7 @@ import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
@Slf4j
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicationTxnTest extends OneWayReplicatorTestBase {
private boolean transactionBufferSegmentedSnapshotEnabled = false;
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorAdminTlsTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorAdminTlsTest.java
index c214378fd94..1035d9eb2c1 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorAdminTlsTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorAdminTlsTest.java
@@ -29,7 +29,7 @@ import org.testng.annotations.AfterClass;
import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicatorAdminTlsTest extends ReplicatorTestBase {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorAdminTlsWithKeyStoreTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorAdminTlsWithKeyStoreTest.java
index 451bdd10eb1..e6b650497a6 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorAdminTlsWithKeyStoreTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorAdminTlsWithKeyStoreTest.java
@@ -29,7 +29,7 @@ import org.testng.annotations.AfterClass;
import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicatorAdminTlsWithKeyStoreTest extends ReplicatorTestBase {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorGlobalNSTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorGlobalNSTest.java
index b0808b20af2..1706d5faf1f 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorGlobalNSTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorGlobalNSTest.java
@@ -50,7 +50,7 @@ import org.testng.annotations.Test;
* a lot of topic deletion and makes namespace policies being incorrect.
*/
@Slf4j
-@Test(groups = "broker-impl")
+@Test(groups = "broker-replication")
public class ReplicatorGlobalNSTest extends ReplicatorTestBase {
protected String methodName;
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRateLimiterTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRateLimiterTest.java
index 767f6eff5c1..1cd3e3b04b6 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRateLimiterTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRateLimiterTest.java
@@ -49,7 +49,7 @@ import org.testng.annotations.Test;
/**
* Starts 3 brokers that are in 3 different clusters.
*/
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicatorRateLimiterTest extends ReplicatorTestBase {
protected String methodName;
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRemoveClusterTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRemoveClusterTest.java
index 28d439f04ef..e62e3a6e856 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRemoveClusterTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRemoveClusterTest.java
@@ -39,7 +39,7 @@ import org.testng.annotations.Test;
/**
* Starts 3 brokers that are in 3 different clusters.
*/
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicatorRemoveClusterTest extends ReplicatorTestBase {
protected String methodName;
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java
index 6e481c8eaff..db3b8eaae1b 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTest.java
@@ -125,7 +125,7 @@ import org.testng.annotations.Test;
/**
* Starts 3 brokers that are in 3 different clusters.
*/
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicatorTest extends ReplicatorTestBase {
protected String methodName;
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTlsTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTlsTest.java
index 4297fcb3943..4dd5b414a70 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTlsTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTlsTest.java
@@ -30,7 +30,7 @@ import org.testng.annotations.AfterClass;
import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicatorTlsTest extends ReplicatorTestBase {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTopicPoliciesTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTopicPoliciesTest.java
index 57dfa1aa820..684eb18f54c 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTopicPoliciesTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTopicPoliciesTest.java
@@ -55,7 +55,7 @@ import org.testng.annotations.Test;
/**
* Starts 3 brokers that are in 3 different clusters.
*/
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class ReplicatorTopicPoliciesTest extends ReplicatorTestBase {
@Override
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TransactionalReplicateSubscriptionTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TransactionalReplicateSubscriptionTest.java
index 7d5dfb87f5b..6a6c760b332 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TransactionalReplicateSubscriptionTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/TransactionalReplicateSubscriptionTest.java
@@ -46,6 +46,7 @@ import org.testng.annotations.AfterClass;
import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
+@Test(groups = "broker-replication")
public class TransactionalReplicateSubscriptionTest extends ReplicatorTestBase
{
@Override
@BeforeClass(timeOut = 300000)
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentReplicatorInflightTaskTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentReplicatorInflightTaskTest.java
index b23b4565e5f..e8a7a11a2db 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentReplicatorInflightTaskTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentReplicatorInflightTaskTest.java
@@ -47,7 +47,7 @@ import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
@Slf4j
-@Test(groups = "broker")
+@Test(groups = "broker-replication")
public class PersistentReplicatorInflightTaskTest extends
OneWayReplicatorTestBase {
private final String topicName =
BrokerTestUtil.newUniqueName("persistent://" + replicatedNamespace + "/tp_");
