Как бы ты проверяла Kafka — что она корректно обрабатывает данные и в случае сбоя корректно восстанавливается?