Test / Verify what happens when Kafka Brokers become 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 when Kafka Brokers become unavailable #102

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