Kafka Streams uses an incremental computation model, ie, each time a new
message arrives, the current session is updated immediately (note that
the result is a `KTable`). -- Kafka Streams does not accumulate the raw
events and computes the session result when the window closes, but it
refines the s
I've following code in my Kafka Streams application:
*.groupBy((_, myobj) => myobj.getId)(Grouped.`with`[String, Myobj])*
*.windowedBy(SessionWindows.`with`(Duration.ofMillis(10 * 60 * 1000)))*
*.count()*
*.toStream*
*.map((k,v) => (k.key(), v))*
*.to("kafka-streams-test")*
Expectation: If
