Re: 答复: Best way to Submit a Job to Storm Topology

Hi Sai and All, What I meant by duplicate issue was that while running the jar through StormSubmitter (which was build through maven) I got duplicate jars present for the Storm which was failing at the job submission. Any workaround or standard practice to avoid the same. Thanks! VM On Mar 30,

Re: Storm KafkaSpout Integration

Hi david, I think everything is good but you are missing a statement config.put(Config.TOPOLOGY_MAX_SPOUT_PENDING, 1); add it after the line config.setDebug(true); *Best regards,* *K.Sai Dilip Reddy.* On Tue, Mar 29, 2016 at 10:03 PM, david kavanagh wrote: > Hi all, >

Re: Failfast error

still waiting for help. *Best regards,* *K.Sai Dilip Reddy,* *Software Engineer - Hadoop Trainee,2-39, Old SBI Road, Sri Nagar Colony, Gannavaram - 521101.* *www.aadhya-analytics.com .* *[image: Inline image 1]* On Fri, Mar 25, 2016 at 11:39 AM, Sai Dilip

Re: 答复: Best way to Submit a Job to Storm Topology

Hello, I don't know if that fits the your case but the standard way of submitting a storm topology AFAIK is the StormSubmitter class. The class source is located here

答复: Best way to Submit a Job to Storm Topology

What duplicate issue? 发件人: Vineet Mishra [mailto:clearmido...@gmail.com] 发送时间: 2016年3月30日 3:59 收件人: user@storm.apache.org 主题: Best way to Submit a Job to Storm Topology Hi All, Its been long since I have been not in touch with Storm and was looking out some standard way to submit a

storm-kafka KafkaSpout always consuming the entire Topic

Hi everyone, What needs to be done in order for a Topology to let the KafkaSpout/Zookeeper know that messages were successfully consumed/processed and should not be sent to that Topology again ? Is it something to be controlled automatically or manually within the Bolt? or Is it set on the

Storm KafkaSpout Integration

Hi all, I am currently trying use TestTopologyStaticHosts to try connect the KafkaSpout to a Kafka topic. I have a ZooKeeper and a Kafka instance running on my localhost. I have a topic named "twitter-topic" that has some tweets in it. This is all working as expected. I can run the consumer in