Spring-XD: Kafka 连接被拒绝

Question

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

有谁知道发生了什么事吗？

Answer 1

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

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

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

Answer 2

事实证明这是防火墙阻止子网之间访问的结果

Spring-XD: Kafka 连接被拒绝

Spring-XD: Kafka Connection refused

apache-kafka

spring-xd

apache-zookeeper