fix test

heesung-sn · Nov 1, 2024 · 6214fe9 · 6214fe9
1 parent f5991a8
commit 6214fe9
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...r-inttest-lib/src/main/java/org/apache/pulsar/tests/integration/utils/IntegTestUtils.java b/...r-inttest-lib/src/main/java/org/apache/pulsar/tests/integration/utils/IntegTestUtils.java
@@ -58,7 +58,9 @@ public static String getNonPartitionedTopic(PulsarAdmin admin, String topicPrefi
             throws Exception {
         String nsName = generateNamespaceName();
         admin.namespaces().createNamespace("public/" + nsName);
-        return generateTopicName(nsName, topicPrefix, isPersistent);
+
+        //TODO: Pass isPersistent, reported in https://github.com/apache/pulsar/issues/23541
+        return generateTopicName(nsName, topicPrefix, true);
     }
 
     public static String getPartitionedTopic(PulsarAdmin admin, String topicPrefix, boolean isPersistent,
@@ -68,7 +70,9 @@ public static String getPartitionedTopic(PulsarAdmin admin, String topicPrefix,
         }
         String nsName = generateNamespaceName();
         admin.namespaces().createNamespace("public/" + nsName);
-        String topicName = generateTopicName(nsName, topicPrefix, isPersistent);
+
+        //TODO: Pass isPersistent, reported in https://github.com/apache/pulsar/issues/23541
+        String topicName = generateTopicName(nsName, topicPrefix, true);
         admin.topics().createPartitionedTopic(topicName, partitions);
         return topicName;
     }