Hi, I have a scenario where I load a collection from MongoDB inside Flink using flink-connector-mongodb. What I additionally want is any future changes (insert/updates) to that collection is also streamed inside my Flink Job.
What I was thinking of is to use a CDC connector to stream data to my Flink job. When researching this I found Flink CDC and they have a CDC connector for MongoDB - flink-connector-mongodb-cdc However I am not able to figure out how to stream those changes also to my Job which is also reading from the same collection. Thanks Sachin
