Fix MetadataUtilsTest

streamnative · May 21, 2021 · 5634ef3 · 5634ef3
1 parent 49eabbb
commit 5634ef3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/kafka-impl/src/test/java/io/streamnative/pulsar/handlers/kop/utils/MetadataUtilsTest.java b/kafka-impl/src/test/java/io/streamnative/pulsar/handlers/kop/utils/MetadataUtilsTest.java
@@ -148,7 +148,7 @@ public void testCreateKafkaMetadataIfMissing() throws Exception {
         verify(mockTenants, times(1)).updateTenant(eq(conf.getKafkaMetadataTenant()), any(TenantInfo.class));
         verify(mockNamespaces, times(2)).setNamespaceReplicationClusters(eq(conf.getKafkaMetadataTenant()
             + "/" + conf.getKafkaMetadataNamespace()), any(Set.class));
-        verify(mockTopics, times(2)).createNonPartitionedTopic(contains(offsetsTopic.getOriginalName()));
-        verify(mockTopics, times(2)).createNonPartitionedTopic(contains(txnTopic.getOriginalName()));
+        verify(mockTopics, times(1)).createMissedPartitions(contains(offsetsTopic.getOriginalName()));
+        verify(mockTopics, times(1)).createMissedPartitions(contains(txnTopic.getOriginalName()));
     }
 }