Storm Dynamic Spout Versions Save

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

0.9.3

5 years ago

Improvement

  • PR-107 Backport fail stream to 0.9 (from 0.10)
  • PR-93 Catch and swallow no-node exceptions

0.9.2

6 years ago

0.9.2 (2017-12-13)

Improvement

  • PR=87 More fair partition distribution

Bug Fixes

  • ISSUE-92 Fix race condition while cleaning up consumer state.
  • PR-86 Sideline payload null checking
  • PR-88 Sideline payload null checking

0.9.0

6 years ago

Improvements

  • PR-14 Update Kafka dependencies to 0.11.0.1
  • PR-15 Update Storm dependencies to 1.1.1
  • PR-24 Add ability for errors to be reported up to the Storm web UI.
  • PR-34 Add removeVirtualSpout() method to DynamicSpout
  • PR-35 Output fields should now be declared as a List of String objects. In 0.10 we will drop the comma delimited strings, in the interim we are also now trimming whitespace off of the comma delimited version.

Bug Fixes

Kafka Consumer
  • PR-16 Improved handling of Out Of Range exceptions
Sideline Spout
  • PR-13 Fixed race condition on-redeploy of Spout when a sideline is active for firehose.

Removed

Kafka Consumer
  • PR-31 Removed configuration items: spout.kafka .autocommit and spout.kafka.autocommit_interval_ms. This functionality is covered by configuration item spout.coordinator.consumer_state_flush_interval_ms

0.8.0

6 years ago

Initial release to maven central.