насколько я понял Рому, он просто хочет записать данны сначала в кафку или локальный файлик, а потом уже дать клиенту отмашку, что данные сохранены.
Если данные из локального файлика не быстро доедут до обработчика(через кафку) его не пугает
сначала в локальный файлик, потом уже в кафку асинхронно ибо не так важно когда события получать остальные сервисы в экосистеме, важно то что событие надёжно записано внутри сервиса, он не должен зависить от внешних систем и в любом случае должен продолжать работать