Возможные тестовые сценарии для потребителя Kafka, который отправляет записи в S3 после обработки

Question

У меня есть Kafka потребитель, который:

1. потребляет записи из Kafka.
2. Параллельно обрабатывает каждую из них, вызывая три нисходящих службы.
3. Вставляет окончательно обработанные документы (соответствующие каждой записи) в S3.

Некоторая дополнительная информация:

1. Я используюcommitAsync(..);

2. Я использую Spring Reactor.

Помимо счастливого случая, какими должны быть возможные сценарии, которые мне следуетпокрытие?Учитывая, что я обрабатываю X количество сообщений на poll(..), обрабатываю и фиксирую их все параллельно?Я хочу, чтобы вся моя программа была протестирована настолько жестко, насколько это возможно.