Hi, I would like to process a stream with a tumbling window of 5secs, create aggregated stats for keys and push the final aggregates at the end of each window period to a analytics backend. I have tried doing something like: stream .map .reduceByKey(... , TimeWindows.of("mywindow", 5000L),...) .foreach { send stats } But I get every update to the ktable in the foreach. How do I just get the final values once the TumblingWindow is complete so I can iterate over them and send to some external system? Thanks, Clive PS Using kafka_2.10-0.10.0.0
- Kafka Streams reducebykey and tumbling window - need final wi... Clive Cox
- Re: Kafka Streams reducebykey and tumbling window - need... Eno Thereska
- Re: Kafka Streams reducebykey and tumbling window - ... Clive Cox
- Re: Kafka Streams reducebykey and tumbling windo... Eno Thereska
- Re: Kafka Streams reducebykey and tumbling w... Clive Cox
- Re: Kafka Streams reducebykey and tumbl... Eno Thereska
- Re: Kafka Streams reducebykey and t... Eno Thereska
- Re: Kafka Streams reducebykey a... Clive Cox
- Re: Kafka Streams reducebykey a... Srikanth
- Re: Kafka Streams reducebykey a... Eno Thereska
- Re: Kafka Streams reducebykey a... Srikanth