Hi All, I have streaming ETL job which takes data from one kafka topic, enriches and writes it to another topic. I want to read one more topic which has the same key and evict the data in state store (added by the processor function) and send some messages to the same kafka topic. Should I be using join to achieve this functionality or can I just use the same processor for two different sources?
Any pointers will be extremely helpful. Thanks
