Rather than fetching the message again you could cache it in the spout and emit it again if the *fail* method is called and delete it when the *ack*method is called. This is possible as Storm guarantees to call the *fail* and *ack* methods with the *messageId* on the exact same spout that the message originated from. This means if you have cached the message there then it will still be available.
On 27 January 2014 19:29, Abhishek Bhattacharjee < abhishek.bhattacharje...@gmail.com> wrote: > I am using storm and kafka for replaying messages. > Now I want to save offset of each message and then use it later for > resending the message. > So my question is how can I fetch a single message using its offset ? > That is I know the offset of a message and I want to use the offset to > fetch that message(only that message). > > > Thanks, > *Abhishek Bhattacharjee* > *Pune Institute of Computer Technology* > -- Cheers Rob.
