Задание:Опишите, как бы вы реализовали отказоустойчивую систему доставки данных из топиков Кафка в распределенное файловое хранилище?

Требования:
гарантия доставки - Exactly Once
выходной формат данных должен позволять читать сообщения (партиция, оффсет, заголовки, ключ, тело сообщения)
задержка между временем сообщения в топике и записью в хранилище не должна быть больше 20 мин
100+ топиков и динамическое подключение новых топиков
20 Тб данных с топиков в сутки
рекомендуемый минимальный размер файла в хранилище 512Мб