Test KafkaSink behavior on Kafka broker outage
Closed this issue · 1 comments
metacret commented
Needs to test and implement remedy for the issue
The first scenario
- Shutdown kafka broker
- Start the producer and produce messages, messages should be dropped immediately
- Start kafka broker
- Produce messages, messages should be sent without any error
The second scenario
- Running kafka, start the producer, produce messages
- Shutdown kafka broker, produce messages, messages should be dropped immediately
- Start kafka broker
- Produce messages, messages should be sent without any error