Re: Streams, Kafka windows

2020-01-18 Thread Viktor Markvardt
Hi John, Thank you for your assistance! Your example very help me and I understood kafka-streams more clearly now. Have a nice weekend :) Best regards, Viktor Markvardt чт, 16 янв. 2020 г. в 19:29, John Roesler : > Hi Viktor, > > I’m starting to wonder what exactly “duplicate” mean

Re: Streams, Kafka windows

2020-01-16 Thread Viktor Markvardt
(Duration.ZERO).advanceBy(Duration.ofSeconds(10))) .count() .suppress(Suppressed.untilWindowCloses(Suppressed.BufferConfig.unbounded())) .toStream(); Best regards, Viktor Markvardt чт, 16 янв. 2020 г. в 04:59, John Roesler : > Hi Viktor, > > I’m not sure why you get two identical o

Streams, Kafka windows

2020-01-14 Thread Viktor Markvardt
recommend me any examples of code or docs please? I have already read official docs and examples but it was not enough to get full understanding of how I can achieve this. Best regards, Viktor Markvardt