我们在脉冲星客户端应用程序中看到了这个例外:
连接代理错误:org.apache.pulsar.client.api.PulsarClientException:java.util.concurrent.CompletionException:org.apache.pulsar.shade.io.netty.channel.AbstractChannel AnnotatedConnectException美元:finishConnect(..) failed:连接拒绝:myserver.mycompany.com/10.20.10.15:6651
它只是随机发生的。尽管测试了不同的客户端设置，我们还是找不到重现它的方法。是什么原因造成的呢?
当客户端所连接的脉冲星代理重新启动时抛出此异常。
脉冲星客户端直接连接到处理客户端正在使用的主题的代理。如果重新启动该代理，连接将断开，并且该代理的主题将被卸载并移动到其他代理。当客户端重新连接时，它应该连接到作为该主题的新所有者的代理，并且通信应该按照预期恢复。由于这个异常偶尔会发生，你可以处理异常(例如使用try/catch)，或者你可以快速失败并强制你的应用程序重新启动，这也会重新建立连接。我通常建议快速失败，以确保异常在日志中显示，以防对事件有关注。