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
[ISSUE-100] - Fix NPE in RatioMessageBuffer on spout deploy #101
Closed
Crim closed 6 years ago
Bugfix for #100
This code would previously NPE on Spout deploy because at deploy time there are no VirtualSpouts to be iterated over.