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
41
stars
13
forks
source link
Catch and swallow no-node exceptions #93
Closed
Crim closed 6 years ago
Fix for #92
Will need to be cherry-picked into the 0.9.x branch as well.