У меня есть следующий код .Моя цель - сгруппировать сообщения по заданному ключу и 10-секундному окну.Я хотел бы посчитать общую сумму, накопленную для определенного ключа в конкретном окне.
Я прочитал, что мне нужно включить кэширование, а также объявить размер кэша.Я также пересылаю настенные часы, чтобы заставить оконное управление включаться и группировать элементы в две отдельные группы.Вы можете увидеть, что я ожидаю от данного кода в двух утверждениях.
К сожалению, этот код не проходит их и делает это двумя способами:
- отправляет результатоперация сокращения каждый раз, когда она выполняется, в отличие от использования кэширования в хранилище и отправки одного общего значения
- окна не соблюдаются, что видно по выводу
Не могли бы вы объяснить мне, как я неправильно понимаю механику потоков Кафки в этом случае?