Skip to main content

Posts

Showing posts from October, 2015

Storm-Esper From Kafka / Zmq / Graphite

This is a Storm-Esper example on vagrant. (From Kafka / Zmq / Graphite) https://github.com/doohee323/tzstorm ===================================== 1. build You can run it on vagrant like this, ./build_deb.sh and you can see the status of storm at http://192.168.82.157:8080. 2. examples There are some examples. 1) Simple storm example /tzstorm/src/main/java/example/tzstorm/TestTopology.java 2) storm + esper example /tzstorm/src/main/java/example2/tzstorm/TestTopology2.java 3) multiple bolts example /tzstorm/src/main/java/example3/tzstorm/TestTopology3.java 4) kafka - storm(multiple bolts) example /tzstorm/src/main/java/example4/tzstorm/TestTopology4.java 5) storm + trident(unique data) + esper example /tzstorm/src/main/java/example5/tzstorm/TestTopology5.java 6) zmq PUB/SUB + storm + trident(unique data) + esper example 7) zmq REP/REQ + storm + trident(unique data) + esper example /tzstorm/src/main/java/example7/tzstorm/T