I am working on DB CDC to Kafka use case. Initially table A is getting populated with multiple records. After some time (varies from days to weeks) Table B is getting populated with single record. Both table has joining columns request_id.
I am creating KTable on TableA to hold data until TableB is populated. And Planning to join TableB KStream with TableA KTable.
How can I join KStream one record with KTable multiple records?