A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
spout.kafka .autocommit
and spout.kafka.autocommit_interval_ms
. This functionality is covered by configuration item spout.coordinator.consumer_state_flush_interval_ms
Initial release to maven central.