Hi, I am a newbie to Kafka Streams and I am using it trying to solve a particular use case. Let me explain.
I have two sources of data both like that: Key (string) DateTime (hourly granularity) Value I need to join the two sources by key and date (hour of day) to obtain: Key (string) DateTime (hourly granularity) ValueSource1 ValueSource2 I think that first I'd need to push the messages in Kafka topics with the date as part of the key because I'll group by key taking into account the date. So maybe the key must be a new string like key_timestamp. But, of course, it is not the main problem, is just an additional explanation. Ok, so data are in topics, here we go! - Multiple records allows per key but only the latest value for a record key will be considered. I should use two KTable with some join strategy, right? - Data of both sources could arrive at any time. What can I do to achieve this? Thanks in advance.