项目作者: LinMingQiang

项目描述 :
storm的相关程序。包括kafka,hbase的结合
高级语言: Java
项目地址: git://github.com/LinMingQiang/storm-demo.git
创建时间: 2017-08-09T14:03:21Z
项目社区:https://github.com/LinMingQiang/storm-demo

开源协议:

下载


storm demo

storm version 1.1.0
kafka version 0.8

  • 提供简单的storm 的wordcount demoe
  • 提供 Storm + Kafka + hbase 的统计demoe

storm的安装

```

  • 解压文件:
    tar -zxvf apache-storm-1.1.0.tar.gz
  • 修改文件conf/storm.yaml
    :每一个配置点前面需要加一个空格“”,否则启动时会报配置文件相关异常。
    storm.zookeeper.servers:
    • “nimbus-ip”
      storm.local.dir: “/mnt/storm”
      nimbus.seeds: [“nimbus-ip”]
      storm.zookeeper.port: 2181
      ui.port: 8080
      nimbus.host: “nimbus-ip”
      supervisor.slots.ports:
      • 6700
      • 6701
      • 6702
      • 6703
        storm.messaging.netty.max_wait_ms: 10000
  • 启动 主节点
    nohup ./storm nimbus >/dev/null &
    启动UI
    nohup ./storm ui >/dev/null &
  • 启动子节点
    nohup ./storm supervisor >/dev/null &
    在work节点上启动日志监控
    nohup ./storm logviewer &

storm的运行
```
./storm jar xxxx.jar xxx.xxx.xxx.xxx.WordCountTest WordCountTest