Fix test

streamnative · Aug 9, 2023 · 5c5e0fc · 5c5e0fc
1 parent f96061b
commit 5c5e0fc
Showing 1 changed file with 3 additions and 3 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
@@ -126,11 +126,11 @@ public void testCreateKafkaMetadataIfMissing() throws Exception {
         verify(mockNamespaces, times(1)).setNamespaceMessageTTL(eq(conf.getKafkaMetadataTenant() + "/"
             + conf.getKafkaMetadataNamespace()), any(Integer.class));
         verify(mockTopics, times(1)).createPartitionedTopic(
-                eq(offsetsTopic.getFullName()), eq(conf.getOffsetsTopicNumPartitions()));
+                eq(offsetsTopic.getFullName()), eq(conf.getOffsetsTopicNumPartitions()), any());
         verify(mockTopics, times(1)).createPartitionedTopic(
-                eq(txnTopic.getFullName()), eq(conf.getKafkaTxnLogTopicNumPartitions()));
+                eq(txnTopic.getFullName()), eq(conf.getKafkaTxnLogTopicNumPartitions()), any());
         verify(mockTopics, times(1)).createPartitionedTopic(
-                eq(txnProducerStateTopic.getFullName()), eq(conf.getKafkaTxnProducerStateTopicNumPartitions()));
+                eq(txnProducerStateTopic.getFullName()), eq(conf.getKafkaTxnProducerStateTopicNumPartitions()), any());
         // check user topics namespace doesn't set the policy
         verify(mockNamespaces, times(1)).createNamespace(eq(conf.getKafkaTenant() + "/"
                 + conf.getKafkaNamespace()), any(Set.class));