I guess you can create your own topology with the reference link below. https://storm.apache.org/documentation/Tutorial.html
Moreover Cassandra will just serve you as persistence layer which you can customize in your code as well. You can probably go with the default implementation of the Storm Topology and make your data persistence in according to what you need for storage as Cassandra, Hbase, Redis or anything as per your call. On Tue, Mar 3, 2015 at 1:34 PM, kay <[email protected]> wrote: > Hi Vineet, > > All ports are opened. It seems that these examples try to create their > own local storm cluster. What I need is working example which I can > alter for my needs. > > Regards. > > On Tue, Mar 3, 2015 at 8:46 AM, Vineet Mishra <[email protected]> > wrote: > > Hi Kay, > > > > It seems like your daemon connectivity is lacking, or perhaps the port is > > not opened for zookeeper connectivity. > > Ensure that all the worker and supervisor are up with access on the > specific > > port. > > > > you can Telnet from the machines to check the connectivity! > > > > > > > > On Mon, Mar 2, 2015 at 7:52 PM, kay <[email protected]> wrote: > >> > >> 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. > > > > >
