Hello storm users, I would like to run a sample kafka-storm-cassandra chain.
Kafka topic should contain simple numbers (10-50 items per second), Storm should read this data and put it into the Cassandra cluster. I've already configured Kafka, Storm and Cassandra clusters. They work well. Storm word-count example works well too (I was able to build example with maven). The rest examples just failed: https://github.com/Parsely/streamparse example failed with the following message: http://pastebin.com/7eMn38BK https://github.com/hmsonline/storm-cassandra example failed on TESTS: http://pastebin.com/vCUyKREJ If I skip tests and try to upload jar into the storm cluster - it can not find the main class: storm jar storm-cassandra-0.4.0-rc5-SNAPSHOT.jar com.hmsonline.storm.cassandra.example.CassandraReachTopology production-topology remote http://pastebin.com/9uTCYSy8 Could someone provide me with the sample kafka-storm-cassandra implementation (just read data from kafka and put it into cassandra table)? It would be great if it will be based on python code. I use Ubuntu 14.04, OpenJDK 7 for kafka, storm and CLI tests run environment (I hope it is not a problem). Cassandra runs under the Oracle Java 7. Thanks in advance.
