You could probably include a timestamp as part of your tuples, and simply reject any tuples at the bolt level if you find their timestamp is too old.
From: Mohsen Bande [mailto:[email protected]] Sent: Monday, November 07, 2016 1:51 AM To: [email protected] Subject: any way to expire tuples after some time Hi Everyone i need tuples in streams to expire if there is no task to process them for a while is there any way to implement this in storm concepts? i'm looking for a way to expire tuples when they are waiting for a bolt to process them. when incoming input tuples rate is higher than bolt processing rate, there is some sort of queue that holds tuples until a bolt take them, right? i want to expire waiting tuples after some time, any help would be highly appreciated
