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. > >
