diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java index f249d5cad7737..e998a02afbc39 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java @@ -631,7 +631,7 @@ public void testReadAheadWhenAddingConsumers() throws Exception { assertTrue(readPosition.getEntryId() < 1000); } - @Test(groups = "quarantine") + @Test public void testRemoveFirstConsumer() throws Exception { this.conf.setSubscriptionKeySharedEnable(true); String topic = "testReadAheadWhenAddingConsumers-" + UUID.randomUUID(); @@ -886,7 +886,7 @@ public void testContinueDispatchMessagesWhenMessageTTL() throws Exception { Assert.assertNotNull(consumer3.receive(1, TimeUnit.SECONDS)); } - @Test(dataProvider = "partitioned", groups = "quarantine") + @Test(dataProvider = "partitioned") public void testOrderingWithConsumerListener(boolean partitioned) throws Exception { final String topic = "persistent://public/default/key_shared-" + UUID.randomUUID(); if (partitioned) {