当getPartitionedTopicMetadata - io.netty.channel.ConnectTimeo



我有一个基本的脉冲星应用程序,当我试图连接到脉冲星,我得到这个例外:

2021-03-10 14:38:26.107警告7——[r-client-io-1-1]connection pool:打开连接失败到myy-puls-serverms-tls.domain.com:6651:io.netty.channel.ConnectTimeoutException:连接超时:my-pulsar-server-ms-tls.domain.com/10.80.13.38:6651 2021-03-1014:38:26.212警告7—[al-listen -3-1][主题]:持久性://myTenant/myNamespace/myTopic]在getPartitionedTopicMetadata时无法连接——会尝试吗再次在100毫秒

我的脉冲星客户端是非常基本的:

PulsarClient.builder()
.serviceUrl(serviceUrl)
.authentication(AuthenticationFactory.token(authToken))
.tlsTrustCertsFilePath(serverCertificateFilePath.toString())
.enableTlsHostnameVerification(false)
.allowTlsInsecureConnection(false)
.build();

生产者也很基本,看起来像这样:

pulsarClient.newProducer(Schema.STRING)
.topic(topic)
.create();

我已经验证令牌和TLS证书是正确的。我还尝试从相同的环境连接消费者并得到类似的异常,并且我知道具有相同代码的其他人能够从其他环境连接到相同的脉冲星群集。问题是什么?

您的连接被防火墙或网络问题阻塞。验证您可以从您的环境建立到端点my-pulsar-server-ms-tls.domain.com:6651的连接。

如果您能够运行网络数据包转储(如tcpdump),那么如果您无法建立连接,应该会很明显。

您也可以尝试运行curl my-pulsar-server-ms-tls.domain.com:6651,如果您返回一些html,这意味着您能够到达服务器。但是,如果您获得Could not resolve host,则您被网络配置(例如缺少路由)或防火墙阻止。

相关内容

最新更新