diff --git a/tests/src/test/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupMetadataManagerTest.java b/tests/src/test/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupMetadataManagerTest.java
index 8dbea74356..b7e184ae9d 100644
--- a/tests/src/test/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupMetadataManagerTest.java
+++ b/tests/src/test/java/io/streamnative/pulsar/handlers/kop/coordinator/group/GroupMetadataManagerTest.java
@@ -130,6 +130,7 @@ public void cleanup() throws Exception {
 
     @BeforeMethod
     protected void setUp() throws PulsarClientException, PulsarAdminException {
+        conf.setOffsetsTopicNumPartitions(numOffsetsPartitions);
         producerBuilder = pulsarClient.newProducer(Schema.BYTEBUFFER);
         readerBuilder = pulsarClient.newReader(Schema.BYTEBUFFER)
                 .startMessageId(MessageId.earliest);
@@ -167,6 +168,7 @@ protected void setUp() throws PulsarClientException, PulsarAdminException {
 
     @AfterMethod
     protected void tearDown() throws PulsarClientException {
+        conf.setOffsetsTopicNumPartitions(numOffsetsPartitions);
         if (consumer != null) {
             consumer.close();
         }