storm-dynamic-spout icon indicating copy to clipboard operation
storm-dynamic-spout copied to clipboard

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

Results 13 storm-dynamic-spout issues
Sort by recently updated
recently updated
newest added

Bumps [guava](https://github.com/google/guava) from 25.1-jre to 29.0-jre. Release notes Sourced from guava's releases. 29.0 Maven <dependency> <groupId>com.google.guava</groupId> <artifactId>guava</artifactId> <version>29.0-jre</version> <!-- or, for Android: --> <version>29.0-android</version> </dependency> Javadoc 29.0-jre 29.0-android JDiff 29.0-jre...

dependencies

Snyk has created this PR to fix one or more vulnerable packages in the `maven` dependencies of this project. #### Changes included in this PR - Changes to the following...

cla:signed

**Test Procedure** * Start a test topology against a kafka cluster * Shutdown one or more zookeeper instances backing the cluster * Determine how the spout responds. * Start zookeeper...

**Test Procedure** * Start a test topology against a kafka cluster * Shutdown one or more brokers in the cluster * Determine how the spout responds. * Start broker(s) back...

We're all over the place with the naming around this. I actually am inclined to think that we should make the following name changes... DelegateSpout => VirtualSpout VirtualSpout => DefaultVirtualSpout

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.

To provide clear separation of concerns between the DynamicSpout framework, the 'Sideline Spout' implementation, and the 'Kafka' consumer implementation, we should separate these out into maven modules.

enhancement

- The 'id' is included in the 'request' already, this is an artifact from the past - we should remove it outright. - The 'type' could be moved into the...

The purpose of this issue to track improvements in our test suite runtime. I cleaned up and reviewed the output from one of our test runs. There are a handful...