提交 2b5bb183 编写于 作者: M massakam 提交者: Jia Zhai

Topic loading in rest-api should time out in zooKeeperOperationTimeoutSeconds (#4805)

(cherry picked from commit abe27e63)
上级 87b557a4
......@@ -1343,7 +1343,7 @@ public class PersistentTopicsBase extends AdminResource {
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;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册