java - Storm - java.net.ConnectException : Connection refused

标签 java apache-zookeeper apache-storm

我已经部署了storm服务器,但是每次启动supervisor时都会收到以下错误。

2014-09-08 09:04:40 o.a.z.ClientCnxn [INFO] Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error)
2014-09-08 09:04:40 o.a.z.ClientCnxn [WARN] 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) ~[na:1.7.0_65]
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) ~[na:1.7.0_65]
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1068) ~[zookeeper-3.4.5.jar:3.4.5-1392090]

任何人都可以帮我解决这个错误吗? 提前致谢

最佳答案

启动 Zookeeper 是我的问题:

zkServer start

之后您应该重新运行拓扑。

关于java - Storm - java.net.ConnectException : Connection refused,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/25720989/

相关文章:

apache-storm - Storm 拓扑配置

java - Google map api 不显示我当前的位置

java - 如何使用java反射仅获取类名而不获取包信息

java - 如何使用 gradle 使 GitLab CI 发布 Spring Boot JAR?

Hbase:此服务器在失败的服务器列表中:localhost/127.0.0.1:38812

kubernetes - 在这个例子中,如何捕获zookeeper-service的IP地址,并将其正确设置到需要它的kafka-broker中?

hadoop - Apache flume 和 Apache storm 有什么区别?

java - 从 Apache Storm Bolt 打印

java - Buffered ObjectInputStream 是否存在?

apache-zookeeper - Zookeeper dataLogDir 配置无效