storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 이승진 <>
Subject Re: Spout fail logic
Date Fri, 04 Jul 2014 05:00:16 GMT
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: &lt;; 
To: &lt;;; 
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



View raw message