storm-dynamic-spout
storm-dynamic-spout copied to clipboard
Test / Verify what happens with zookeeper cluster becomes unavailable
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.