diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java index 8eef9259de79f..1a08e6ced9ca8 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java @@ -227,7 +227,8 @@ protected void internalDeleteNamespace(AsyncResponse asyncResponse, boolean auth boolean isEmpty; List topics; try { - topics = pulsar().getNamespaceService().getListOfPersistentTopics(namespaceName).join(); + topics = pulsar().getNamespaceService().getListOfPersistentTopics(namespaceName) + .get(config().getZooKeeperOperationTimeoutSeconds(), TimeUnit.SECONDS); topics.addAll(getPartitionedTopicList(TopicDomain.persistent)); topics.addAll(getPartitionedTopicList(TopicDomain.non_persistent)); isEmpty = topics.isEmpty();