enhance test

apache · Sep 14, 2022 · b74b8ec · b74b8ec
1 parent b0fd7a5
commit b74b8ec
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicAutoCreationTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicAutoCreationTest.java
@@ -23,6 +23,7 @@
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 import static org.testng.Assert.assertEquals;
+import static org.testng.Assert.assertTrue;
 import java.net.InetSocketAddress;
 import java.util.List;
 import java.util.UUID;
@@ -143,13 +144,19 @@ public void testPartitionedTopicAutoCreationForbiddenDuringNamespaceDeletion()
                     .topic(topic)
                     .create();) {
             } catch (PulsarClientException.LookupException expected) {
+                String msg = "Namespace bundle for topic (%s) not served by this instance";
+                log.info("Expected error", expected);
+                assertTrue(expected.getMessage().contains(String.format(msg, topic)));
             }
 
             try (Consumer<byte[]> consumer = pulsarClient.newConsumer()
                     .topic(topic)
                     .subscriptionName("test")
                     .subscribe();) {
             } catch (PulsarClientException.LookupException expected) {
+                String msg = "Namespace bundle for topic (%s) not served by this instance";
+                log.info("Expected error", expected);
+                assertTrue(expected.getMessage().contains(String.format(msg, topic)));
             }