Hi, I am trying to create a loop in Storm. To do this, I would like to be able to replay a Tuple across a series of Bolts until certain criteria are met. One of them being max loops so that it does not go into a never ending loop.
The way I would like to do this is by (ab)using the internal messaging system. Is there a way I can create an OutputCollector which submits records to a Task ID that I provide? That way, I would not need to worry if Storm is using ZeroMQ or Netty under the hood. Thanks in advance, Pieter-Jan Van Aeken
