Hello, I have a Kafka producer and a Kafka consumer that produces and consumes multiple data respectively. You can think of two data sets here. Both datasets have a similar structure but carry different data.
I want to implement a Table API to join two Kafka streams while I consume them. For example, data1.ssn==data2.ssn Constraints: I don't want to change my producer or use FlinkKafkaProducer. Thank you very much. Best, Amir
