No storm does not take care of replaying message
 
It just calls spout's fail method 
 
When you look at KafkaSpout's fail method, there's a logic in case of failure.
 
Currently, it fetches buffer size of data again from the offset and checks if they are already processed, and if not, replay that message.
 
In short, exactly-once message processing is not guaranteed by storm but implemented by KafkaSpout in its own way.


-----Original Message-----
From: <francesco.masucci@pronetics.it> 
To: <user@storm.incubator.apache.org>; 
Cc: 
Sent: 2014-07-03 (목) 22:45:27
Subject: Re: Spout fail logic




Storm will take care of the replay of the message 

 

Francesco Maria Masucci

 

 

Il 2014-07-03 15:15 Tomas Mazukna ha scritto:


If a spout receives fail on the message, will storm replay the message, or spout needs to re-emit it again?-- 
Tomas Mazukna