Kafka Stream KTable с задержкой

Question

Насколько я знаю, Kafka Stream обрабатывает сообщения "как только приходит". Но когда я использую Kafka Stream для обработки KTable (например, пример подсчета слов в документации ), он имеет некоторую задержку (до секунд) для группировки и отображения количества слов для вывода topi c.
Is это нормальная или любая другая конфигурация, которую мне нужно установить?

Answer 1

Если мы установим commit.interval.ms = 0, Kafka Stream выполнит смещение как можно скорее.

Обратите внимание: если processing.guarantee установлено на exactly_once, значение по умолчанию равно 100, в противном случае значение по умолчанию составляет 30000 мсек.

Из официальных документов Kafka Streams - https://kafka.apache.org/documentation/#streamsconfigs