在本地集群模式下运行 Apache Storm 是否需要本地 Zookeeper 集群？

Question

我一直在尝试让 Storm 的本地副本正常工作，遵循 storm-starter repo, and this tutorial 中的指南。

当尝试运行具有 mvn compile exec:java -Dstorm.topology=org.apache.storm.starter.ExclamationTopology 的拓扑时，输出最终继续循环和垃圾邮件：

28534 [Thread-9-SendThread(localhost:2000)] INFO  o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error)
28534 [Thread-9-SendThread(localhost:2000)] WARN  o.a.s.s.o.a.z.ClientCnxn - Session 0x152f7728a6a0011 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
  at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[?:1.8.0_45]
  at Sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[?:1.8.0_45]
  at org.apache.storm.shade.org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361) ~[storm-core-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
  at org.apache.storm.shade.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081) [storm-core-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]

它似乎正在尝试连接到本地 Zookeeper 集群，但我没有在 Storm 文档或其他教程中看到 Zookeeper 的依赖项或安装要求。

我需要安装 Zookeeper 吗？文档中是否缺少这个？也许我弄错了，它正在我本地主机的 2000 端口寻找其他东西？如果不是，我的本地设置出了什么问题？

Answer 1

如果您运行在本地使用 LocalCluter，则 不需要 安装 Zookeeper。

如果您运行在本地以伪分布式模式（即在本地启动 Nimubs 和 Supervisor）并使用 StormSubmitter，您需要在本地安装 Zookeeper。

在本地集群模式下运行 Apache Storm 是否需要本地 Zookeeper 集群？

Is a local Zookeeper cluster required to run Apache Storm in local cluster mode?

apache-storm

apache-zookeeper

在本地集群模式下 运行 Apache Storm 是否需要本地 Zookeeper 集群？

Is a local Zookeeper cluster required to run Apache Storm in local cluster mode?

apache-storm

apache-zookeeper

在本地集群模式下运行 Apache Storm 是否需要本地 Zookeeper 集群？