I like the idea to test the error case -- expect it to be tricky with at-least-once delivery.
We could still do it in integration tests, too, using Two `KafkaStreams` instances and let one die, such that the other one takes over. As an alternative, you can just use a single one, kill it, and restart a new one -- maybe we actually want to test both cases? [ Full content available at: https://github.com/apache/kafka/pull/5724 ] This message was relayed via gitbox.apache.org for [email protected]
