Partition{1} of topic{TOPIC_A} and
Worker{IP_B{ is reading Partition{0} of topic{TOPIC_A}
Thanks and regards!!
--
Andres Gomez Ferrer
Do you use trindent or only storm???
Regards,
Andres
El 02/06/2014, a las 10:43, Komal Thombare komal.thomb...@tcs.com escribió:
Hi,
I am trying to integrate storm with kafka, but did not get any proper
documentation to do so.
Can anyone please help me for getting started with the
You should make a clone of this project:
https://github.com/apache/incubator-storm/tree/master/external/storm-kafka
and do “mvn install”, I suposse you use kafka 0.8.+
and then you do this:
SpoutConfig spoutConfig = new SpoutConfig();
spoutConfig.zkServers = “localhost”; //zookeeper Host
unusual?
Andres Gomez
El 28/05/2014, a las 21:42, Danijel Schiavuzzi dani...@schiavuzzi.com
escribió:
I'm using the same Kafka transactional trident spout in a production Trident
topology and haven't experienced any problems with ZooKeeper. Could you post
your ZooKeeper and any Storm custom
Hi all,
I use storm with kafka! Actually, I use a topology with trident storm =
when I use:
1- trasactional trident spout
2- Some functions
I have a problem in my zookeeper cluster, because storm continually =
writes at zkPath -- /trasactional/ and this generate a lot of logs and =
snapshot by
