Test / Verify what happens with zookeeper cluster becomes unavailable

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

41 stars 13 forks source link

Test / Verify what happens with zookeeper cluster becomes unavailable #103

Open Crim opened 6 years ago

Crim commented 6 years ago

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 instances.

Expected Behavior It's expected that the spout will gracefully degrade, and once the zk instance becomes available again it correct resumes consuming. If this is NOT what happens, lodge additional issues/work items to correct the behavior.