Spring-XD：卡夫卡连接被拒绝答案

【问题标题】：Spring-XD: Kafka Connection refusedSpring-XD：卡夫卡连接被拒绝
【发布时间】：2015-06-03 04:42:06
【问题描述】：

我正在尝试使用spring-xd构建一个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 实例，也会发生这种情况，并且具有全局可用的安全性

有人知道发生了什么吗？

【问题讨论】：

Zookeeper 真的在监听那个主机/端口吗？是否涉及防火墙？尝试使用网络跟踪（如wireshark）来调试连接问题。
是的，看起来传出流量在网络级别被阻止了

标签： apache-zookeeper apache-kafka spring-xd

【解决方案1】：

2015-05-22 17:49:46,973 1.1.2.RELEASE WARN DeploymentsPathChildrenCache-0-SendThread(52.5.7.194:2181) zookeeper.ClientCnxn - 服务器为空的会话 0x0，意外错误，关闭套接字连接并尝试重新连接 java.net.ConnectException：连接被拒绝

该异常表明您的 XD 容器尚未向 ZK 注册，因为它在连接到 ZK 时出现问题。因此，这发生在您的实际流被部署之前。

我猜你是在分布式模式下运行 XD。确保您的容器服务器可以连接到 ZK。

【讨论】：

【解决方案2】：

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

【讨论】：