diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java index 8c51b0379b62b..4c06610dbb423 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java @@ -1343,7 +1343,7 @@ public static CompletableFuture getPartitionedTopicMet private Topic getTopicReference(TopicName topicName) { try { return pulsar().getBrokerService().getTopicIfExists(topicName.toString()) - .get(pulsar().getConfiguration().getZooKeeperSessionTimeoutMillis(), TimeUnit.MILLISECONDS) + .get(pulsar().getConfiguration().getZooKeeperOperationTimeoutSeconds(), TimeUnit.SECONDS) .orElseThrow(() -> topicNotFoundReason(topicName)); } catch (RestException e) { throw e;