Hi Vineet, Thank you very much for your advice, but the problem is that I've never worked with java, scala. And all these tutorials looks like http://knowyourmeme.com/memes/how-to-draw-an-owl for me. I really hope that there is a simple working example somewhere which shows how to read data from kafka and save it into sample cassandra table.
Regards. On Tue, Mar 3, 2015 at 9:18 AM, Vineet Mishra <[email protected]> wrote: > 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. >> > >> > > >
