У меня есть два потребителя kafka для одной и той же темы, и я хочу присоединиться ко второму потоку первым после вычисления нескольких подзадач в первом потоке, а затем проверить запись.KT - C1, C2
KT - C1 - Преобразование (FlatMap) - дедупликация - проверка --ifvalidsave его в DB
-C2 - процесс --------------------------
если запись недействительна, сохраните ее в теме ошибок.
Как объединить эти два потока: один быстрый, а другой - немного медленный(два уровня вычислений)?
объединить два потока нажмите здесь, чтобы увидеть его