Kafka Streams question - KStream.leftJoin(KTable)

Hi Guys, I am implementing a stream processor where I aggregate a stream of events by their keys into a KTable tableA and then I am “enriching” another streamB by the values of tableA. So essentially I have this: streamC = streamB .selectKey(..) .leftJoin(tableA); This works great however i

Priority queue using Kafka Streams' KStream

Hi guys, Got a quick question on how one would go about implementing a priority queue using Kafka Streams DSL API. This is probably closely related to windowed sort but I haven't found an example of how that can be accomplished. Regards, -Ivan