I've created a JIRA ticket FLINK-38606 <https://issues.apache.org/jira/browse/FLINK-38606> for adding flink 2.1.0 support to the flink mongodb connector. I've raise a pull request with the JIRA ticket as well [FLINK-38606][Connectors/MongoDB] Support for Flink 2.1.0 API by neoneo008 · Pull Request #57 · apache/flink-connector-mongodb <https://github.com/apache/flink-connector-mongodb/pull/57>
Below changes are required for support Source: API change for SingleThreadFetcherManager constructor to remove FutureCompletingBlockingQueue. This is now created internally by SingeThreadFetcherManager using Configuration for queue capacity. Sink: Migrate from InitContext to WriterInitContext (API change in flink 2.x) Can some help review? Happy to address any review comments or suggestions. Best, Rahul Teke
