A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
BSD 3-Clause "New" or "Revised" License
40
stars
13
forks
source link
Refactor to use kafka-junit external dependency #52
Closed
Crim closed 6 years ago
Resolves issue: https://github.com/salesforce/storm-dynamic-spout/issues/51