We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9a6b619 commit 027ecfcCopy full SHA for 027ecfc
1 file changed
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApi2Test.java
@@ -3746,6 +3746,7 @@ public void testGetStatsIfPartitionNotExists() throws Exception {
3746
final String partitionedTp = BrokerTestUtil.newUniqueName("persistent://" + defaultNamespace + "/tp");
3747
admin.topics().createPartitionedTopic(partitionedTp, 1);
3748
TopicName partition0 = TopicName.get(partitionedTp).getPartition(0);
3749
+ admin.lookups().lookupTopic(partition0.toString()); // trigger loading namespace bundles
3750
boolean topicExists1 = pulsar.getBrokerService().getTopic(partition0.toString(), false).join().isPresent();
3751
assertTrue(topicExists1);
3752
// Verify topics-stats works.
0 commit comments