salesforce/storm-dynamic-spout
A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
JavaBSD-3-Clause
A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
JavaBSD-3-Clause