spring xd:kafka连接被拒绝

pxiryf3j 于 2021-06-08 发布在 Kafka

关注(0)|答案(2)|浏览(360)

我试图使用springxd来构建kafka消费者，但是不管我为zkconnect提供什么，它都告诉我连接是混乱的

stream create kafka-source-test --definition "kafka  --groupId=xd-test --zkconnect=52.5.7.194:2181 --topic=vehicle-data | log" --deploy

这将产生：

2015-05-22 17:49:46,973 1.1.2.RELEASE  WARN DeploymentsPathChildrenCache-0-SendThread(52.5.7.194:2181) zookeeper.ClientCnxn - Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739)
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081)

即使我有几个其他客户端连接到同一个zookeeper示例，并且具有全局可用的安全性，也会发生这种情况
有人知道发生了什么事吗？

apache-kafka apache-zookeeper spring-xd

来源：https://stackoverflow.com/questions/30402983/spring-xd-kafka-connection-refused

2条答案

按热度按时间

kxe2p93d1#

2015-05-22 17:49:46973 1.1.2.release warn deploymentspathchildrencache-0-sendthread（52.5.7.194:2181）zookeeper.clientcnxn-服务器为空的会话0x0，意外错误，正在关闭套接字连接并尝试重新连接java.net.connectexception:连接被拒绝
该异常表示您的xd容器尚未向zk注册，因为它在连接到zk时出现问题。所以，这在实际流部署之前就发生了。
我猜您正在分布式模式下运行xd。确保容器服务器可以连接到zk。

赞(0）回复(0）举报 2021-06-08

iih3973s2#

原来这是防火墙阻止子网之间访问的结果

赞(0）回复(0）举报 2021-06-08