storm-contrib icon indicating copy to clipboard operation
storm-contrib copied to clipboard

StreamID for kafka-spout emits?

Open ghost opened this issue 12 years ago • 1 comments

If I've a number of spout implementations in a plant, and they are all using the KafkaSpout implementation... is there any means or desire for a means (other than mine own) to explicit control the streamId the spout emits to?

Use case: Using the documented "forceStartOffsetTime" at some future time, I may want to emit the recovery (depending on its currency of priority of originating request"), send some input down a "special" stream. Its not clear I could mimic this behavior with a separate spout; even if I could set the "emitTo" streamId.

thoughts?

ghost avatar Jun 13 '12 16:06 ghost

Any updates on this?

hitejinder avatar Aug 05 '15 21:08 hitejinder