henriquekops/ApacheStormStudy

Java

ApacheStormStudy

A simple program to run apache storm stream processing

How to run

Start the cluster with

$ docker-compose up -d

Install python dependencies using virtual environments with

$ python -m venv venv
$ . venv/bin/activate
$ pip install -r requirements.txt

Execute the kafka producer with

$ python producer.py

Note: this producer uses MacOSX top command, so you may change it at variable CMD

Run the topology with

$ . bin/run-top-topology.sh

Finally, access the storm UI at http://localhost:8080

Refs