Skip to content
This repository has been archived by the owner on Feb 12, 2022. It is now read-only.

Releases: salesforce/storm-dynamic-spout

0.9.3

28 Jun 14:47
Compare
Choose a tag to compare

Improvement

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

0.9.2

14 Dec 03:43
Compare
Choose a tag to compare

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

Upgrades to Kafka & Storm and bug fixes

27 Oct 01:57
Compare
Choose a tag to compare

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

v0.8.0

13 Oct 03:25
Compare
Choose a tag to compare

Initial release to maven central.