первая вычитывает в память данные из топика Кафка (все данные от начала и до конца), вторая использует эти данные для своих коварных целей.
Как поймать момент, когда данные первого топика, доступные на момент старта приложения, вычитаны полностью и можно с ними работать?
православно никак поток - неограниченные данные
как определена эта полнота? какой-то ватермарк есть, или вы его хотите сгенерировать?
конец данных конечен или топик все время пополяется?
Обсуждают сегодня