У меня агрегированное хранилище через DSL через оконную агрегацию через поток.Затем я получаю из него поток через toStream, выполняю небольшое преобразование и отправляю в другую тему.
В моих тестах, начиная со времени публикации и заканчивая временем, когда данные находятся в потоке назначения, онвполне может потратить 10-20 секунд.Что заставляет мои тесты ждать его так долго.
Как я могу сократить это время ожидания, чтобы вычисления быстрее выполнялись в моих тестах?
Какие настройки задействованы?
Я попытался установить commit.interval.ms на 100, но это не помогло.