Все в канале это сложное понятие, там нельзя сделать snapshot, поэтому можно вычитывать долго, пока пишут. Поэтому хочется добавить какие-то условия когда перестать читать и начать обрабатывать (1000 сообщений или 1 секунда)
Получается вычитывать не "все", а вычитывать "batch с условиями по времени, количеству, предикату"