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