(DEPRECATED) Apache Flink User Mailing List archive.

Re: Flink Table SQL and MongoDB connector?

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

Hi Dan,

afaik Flink does not have a dedicated MongoDB connector (except for the DataSet API which is rather old). Hence I believe that the 2nd option seems to be more promising.

Cheers,

Till

On Thu, Oct 22, 2020 at 6:45 AM Dan Hill <[hidden email]> wrote:

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