Polina Koleva I attempted to do this with streams, using group by key and other methods. With group by key the main problem is I can't figure out how to manipulate the groups. The other solutions seem quite inefficient. As for using a consumer, if we can only delete one token at a time, thats also not optimal, compared to how it was before