Has anyone connected these two? Looking through previous emails and the Flink docs, I've see two mentions of how to hook up MongoDB to Flink.
1) https://github.com/okkam-it/flink-mongodb-test 2) Debezium->Kafka->Flink https://debezium.io/documentation/reference/1.3/connectors/mongodb.html The debezium route has more setup and maintenance work but scales better and probably has an easier hook for Table SQL (since it's Kafka).