Как вы взаимодействовали с источниками данных? Предоставляли API-ручки, писали в Kafka или читали из Kafka?

Разделите роли интеграции: кто владел данными, кто инициировал передачу и как подтверждалась обработка. API, публикация и чтение Kafka могут сочетаться в одном процессе.

Опишите конкретный поток и его контракт: схема данных, частота изменений, дедупликация, порядок, повторная загрузка. Для API важны пагинация и лимиты, для событий — offsets, lag и восстановление после сбоя.

Если использовали несколько источников, поясните, как разрешали расхождения и где был источник истины. Не заменяйте ответ перечислением технологий без направления движения данных.