自动化Apache STORM部署

您可以使用Docker部署伪分布式集群: https://registry.hub.docker.com/u/fhuz/docker-storm/

我不能推荐 wirbelsturm 足够高。

我们用它来启动类似于开发环境的生产。

您可以在一台机器上参考以下Apache风暴部署链接:

https://github.com/nathanmarz/storm/wiki/Setting-up-development-environment

http://10jumps.com/blog/storm-installation-single-machine

在本地机器上运行Apache Storm进行测试非常简单。结账 Storm Local Mode .

如果使用以下代码,拓扑将通过活动nimbus节点提交给集群。

StormSubmitter.submitTopology("Topology_Name", conf, Topology_Object);

但如果使用以下代码,拓扑将在同一台机器上本地提交。在这种情况下,将在同一台机器中创建一个新的本地集群,其中包含nimbus、动物园管理员和管理员。

LocalCluster cluster = new LocalCluster();
cluster.submitTopology("Topology_Name", conf, Topology_Object);