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 26819c8f1d002..75e214f19bfbd 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
@@ -85,7 +85,6 @@
 import org.mockito.Mockito;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.testng.Assert;
 import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.BeforeMethod;
@@ -824,17 +823,17 @@ public void testReplicatorWithPartitionedTopic() throws Exception {
         assertEquals(admin2.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 5);
         assertEquals(admin2.topics().getList(namespace).size(), 5);
         // Update partitioned topic from R3
-        admin3.topics().updatePartitionedTopic(persistentTopicName, 5);
-        assertEquals(admin3.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 5);
-        assertEquals(admin3.topics().getList(namespace).size(), 5);
-        // Update partitioned topic from R1
-        admin1.topics().updatePartitionedTopic(persistentTopicName, 6);
-        assertEquals(admin1.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 6);
-        assertEquals(admin2.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 6);
+        admin3.topics().updatePartitionedTopic(persistentTopicName, 6);
         assertEquals(admin3.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 6);
-        assertEquals(admin1.topics().getList(namespace).size(), 6);
-        assertEquals(admin2.topics().getList(namespace).size(), 6);
         assertEquals(admin3.topics().getList(namespace).size(), 6);
+        // Update partitioned topic from R1
+        admin1.topics().updatePartitionedTopic(persistentTopicName, 7);
+        assertEquals(admin1.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 7);
+        assertEquals(admin2.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 7);
+        assertEquals(admin3.topics().getPartitionedTopicMetadata(persistentTopicName).partitions, 7);
+        assertEquals(admin1.topics().getList(namespace).size(), 7);
+        assertEquals(admin2.topics().getList(namespace).size(), 7);
+        assertEquals(admin3.topics().getList(namespace).size(), 7);
     }
 
     /**