Flink Table SQL and MongoDB connector?

Posted by Dan on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-Table-SQL-and-MongoDB-connector-tp38864.html

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).