берет из кафки месседж, кладет в стор(кеш/бд/etc)
таких стримов несколько, есть отдельный стрим, который слушает сторы (или оригинальные стримы из кафки, не суть), и делает merge/zip на них
ну и не просто мерж, а с фильтрацией, конвертацией, так далее, пока не положит в след топик кафки
и вот возникает вопрос - как тестировать это чейн с его условиями?
тестировать только операторы и забить на чейн?
тестировать через интеграционник все кейсы?
тестировать, что чейн для определенных входных параметров вызывает определенные операторы, и отдельно тестить операторы?
Я на прошлой работе написал порядка 20-30 таких сервисов, так что чуть-чуть знаю про тестирование онных. Но мой ответ будет короток - интеграционно такое тестировать не дорого. Дорого такое НЕ тестировать интеграционно 😄
Обсуждают сегодня