The Kafka spout has guaranteed messaging processing turned on . Your bolt mist ack the incoming tuple. If you extend BaseBasicBolt , it has acknowledge builtin . Hope this solves your problem.
-----Original Message----- From: Kushan Maskey Sent: 08-08-2014 AM 02:11 To: [email protected] Subject: KafkaSpout repeatedly sending the same message over and over again I have a topology based on Storm 0.9.2 which makes use of in built KafkaSpout. I build the topology as BrokerHosts zkHosts = new ZkHosts("mykafkahost"); SpoutConfig config = new SpoutConfig(zkHosts, topic, /kafkastorm, id); config.scheme = new RawMultiScheme(); KafkaSpout spout = new KafkaSpout(config); builder.setSpout("mySpout", spout); builder.setBolt("myBolt", new MyBolt()).shuffleGrouping("mySpout"); builder.setBolt("myBolt1", new MyBolt1()).shuffleGrouping("myBolt"); When I execute this topology, I receive the message but the spout keeps reading the same message again and again. I am adding the data into the database and its causing me to have duplicate as I create a GUID for each time it executes MyBolt and MyBolt1. Any idea whats the issue here? Am I missing any configuration on the spoutConfig? Thanks. -- Kushan Maskey 817.403.7500
