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
Define Concrete Config classes for DynamicSpout, Sideline, and KafkaConsumer #80
Open
Crim opened 6 years ago
Right now we pass Maps around for all of these configs. We should work out how to create a concrete object to represent these configurations.