研究一天终于搞明白了。
如果用下面方式提交:[mw_shl_code=actionscript3,true]LocalCluster cluster = new LocalCluster();
cluster.submitTopology(TOPOLOGY_NAME, config, builder.createTopology());[/mw_shl_code]
就不需要运行zookeeper,nimbus,supervisor,在storm ui也不会显示topology,因为是本地模拟。
如果用下面方式:[mw_shl_code=actionscript3,true]StormSubmitter.submitTopology(TOPOLOGY_NAME, config, builder.createTopology());[/mw_shl_code]
则需要启动zookeeper,nimbus,supervisor,会在storm ui显示 |