1.安装zookeeper
这个就不说了,简单的很
创建一下 数据目录
mkdir /var/storm
2.storm.yaml 最简单配置[ 每台机器 storm.yaml 配置文件一样 ]:
storm.zookeeper.servers:
- "192.168.18.128"
nimbus.seeds: ["192.168.18.128"]
storm.local.dir: "/var/storm"
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
3.配置 环境变量
STORM_HOME=/usr/local/storm
export STORM_HOME
PATH=$STORM_HOME/bin:$PATH
4. 启动 storm [ storm ui 可以只启动一台 ]
启动 storm nimbus
storm nimbus >/dev/null 2>&1 &
启动 Supervisor:
storm supervisor >/dev/null 2>&1 &
启动 UI:
storm ui >/dev/null 2>&1 &
启动日志:
storm logviewer >/dev/null 2>&1 &
提交 jar 到 storm集群 运行:
storm jar mycode.jar com.hello.storm.WordCountTopology WordCountTopology
kill Topo 任务:
storm kill WordCountTopology
查看 storm ui 日志:
