Hi Ali,
(My use case is, i receive a stream of messages. Messages need to be stored > and sorted into 'buckets', to indicate 'sessions'. Each time there's a gap > of 30 mins or more since the last message (under a key), a new 'session' > (bucket) should be started, and future messages should belong to that > 'session', until the next 30+ min gap). > > This sounds like you might want to use the SessionWindows feature in KafkaStreams. https://kafka.apache.org/0102/javadoc/org/apache/kafka/streams/kstream/SessionWindows.html
