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

Reply via email to