STORM 本地开发环境配置

本文将指导你配置Storm的开发环境

Storm

Storm

1.下载最新版本并解压

Storm官方下载最新版本

2.配置$STORM_HOME/conf/storm.yaml

storm.zookeeper.servers:
    - "127.0.0.1"
nimbus.seeds: ["127.0.0.1"]
storm.local.dir: "/Users/haseochen/app/apache-storm-1.2.1"
supervisor.slots.ports:
    - 6700
    - 6701
    - 6702
    - 6703
storm.zookeeper.servers:
  - "127.0.0.1"
storm.health.check.dir: "healthchecks"
storm.health.check.timeout.ms: 5000

ZooKeeper

1.下载ZooKeeper

ZooKeeper官方下载最新版

2.复制配置文件

cp zookeeper-3.4.10/conf/zoo_sample.cfg zookeeper-3.4.10/conf/zoo.cfg

启动服务

1.启动zookeeper server

zookeeper-3.4.10/bin/zkServer.sh start

2.启动storm server

apache-storm-1.2.1/bin/storm nimbus

3.启动 supervisor

apache-storm-1.2.1/bin/storm supervisor

4.启动 storm ui

可以通过 http://localhost:8080/index.html 访问

apache-storm-1.2.1/bin/storm ui

运行Storm程序

helloworld.jar是我们打包的Storm程序,TopologyMain为主程序

apache-storm-1.2.1/bin/storm jar ~/helloworld.jar TopologyMain

参考

Setting up a Storm Cluster

打赏支持:如果你觉得我的文章对你有所帮助,可以打赏我哟。