макс значение по ключу и punctuate вызывается раз в 10 сек, то если макс значение придет через 11 сек - у меня будут 2 сообщения в аутпут топике?
т.е. по одной записи на каждый вызов punctuate?
Punctuate вызывается с указанным интервалом, соответственно, на каждый вызов будет выполнено какое-то действие. Когда придет максимальное значение не столь принципиально, важно, что оно будет искаться каждые 10 секунд. https://kafka.apache.org/10/documentation/streams/developer-guide/processor-api.html#defining-a-stream-processor
Обсуждают сегодня