storm-dynamic-spout
storm-dynamic-spout copied to clipboard
Test / Verify what happens when Kafka Brokers become unavailable
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 up, determine how the spout responds.
Expected Behavior It's expected that the spout will gracefully degrade, and once the broker becomes available again it correct resumes consuming. If this is NOT what happens, lodge additional issues/work items to correct the behavior.