search

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.
BSD 3-Clause "New" or "Revised" License
40 stars 13 forks source link

Allow ending state to be set after a VirtualSpout has been created #69

Closed stanlemon closed 6 years ago

stanlemon commented 6 years ago

This is being added so that you can create an open ended spout, meaning one where you don't yet know the ending state but might need to set it down the road. This is the first step in moving our sideline implementation to support what's been called 'throttling'.