Apache pulsar以不可预测的方式获得超时

Question

我独立安装了阿帕奇脉冲星。脉冲星有时会超时。它与高吞吐量无关，也与特定主题(遵循日志)无关。Pulsar-admin代理健康检查返回OK或timeout。如何进行调查？

10:46:46.365 [pulsar-ordered-OrderedExecutor-7-0] WARN  org.apache.pulsar.broker.service.BrokerService - Got exception when reading persistence policy for persistent://nnx/agent_ns/action_up-53da8177-b4b9-4b92-8f75-efe94dc2309d: null
java.util.concurrent.TimeoutException: null
        at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) ~[?:1.8.0_232]
        at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) ~[?:1.8.0_232]
        at org.apache.pulsar.zookeeper.ZooKeeperDataCache.get(ZooKeeperDataCache.java:97) ~[org.apache.pulsar-pulsar-zookeeper-utils-2.5.0.jar:2.5.0]
        at org.apache.pulsar.broker.service.BrokerService.lambda$getManagedLedgerConfig$32(BrokerService.java:922) ~[org.apache.pulsar-pulsar-broker-2.5.0.jar:2.5.0]
        at org.apache.bookkeeper.mledger.util.SafeRun$2.safeRun(SafeRun.java:49) [org.apache.pulsar-managed-ledger-2.5.0.jar:2.5.0]
        at org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36) [org.apache.bookkeeper-bookkeeper-common-4.10.0.jar:4.10.0]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_232]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_232]
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]

Answer 1

如果您使用的是任何TLScertificate文件路径，您可以检查与服务器的连接看起来是否存在连接问题。检查您是否拥有正确的证书。问题是我们没有太多的解决方案在互联网上的阿帕奇脉冲星，但如果你正在关注阿帕奇脉冲星文档可能会有所帮助，我们也有阿帕奇脉冲星git集线器和样本项目。

Answer 2

我很高兴你能够通过添加更多的内核来解决这个问题。问题是在尝试访问存储在ZookKeeper中的某些主题元数据时连接超时，如堆栈跟踪中的以下行所示：

在org.apache.pulsar.zookeeper.ZooKeeperDataCache.get(ZooKeeperDataCache.java:97) ~org.apache.pulsar-pulsar-zookeeper-utils-2.5.0.jar:2.5.0

增加核心必须释放足够的线程，以允许ZK节点响应此请求。