Apache Storm Topology used by cenote for data writing
- The
kafka-spout
Spout is connected to a kafka topic calledcenoteIncoming
. - Everytime it consumes a message, it passes it down to
forwardToCassandra
Bolt. - This bolt (which is written in Python) connects to a cassandra keyspace called
cenote
, and handles the data writing accoring to cenote's specs.
- Compile the source code:
$ mvn clean install package
- Submit the topology to the cluster:
$ storm jar path/to/write-0.1.0-jar-with-dependencies.jar com.issel.cenote.WriteTopology WriteTopology