1

我独立安装了 Apache pulsar。Pulsar 有时会超时。它与高吞吐量无关，也与特定主题（以下日志）无关。Pulsar-admin 代理运行状况检查也返回 OK 或超时。如何对此进行调查？

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]
4

2 回答 2

0

如果您使用任何 TLScertificate 文件路径检查您是否拥有正确的证书，您可以检查与服务器的连接看起来像连接问题。问题是我们在互联网上没有很多针对 apache pulsar 的解决方案，但是如果您关注 apache pulsar doc 可能会有所帮助，而且我们还有 apache pulsar git hub 和示例项目。

于 2020-04-16T23:20:46.460 回答
0

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

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

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

于 2020-05-07T15:31:21.680 回答