Flink CDC for mongoDB, need to understand MongoDBStreamFetchTask better

Hi, I seem to have some difficulty in understanding the code for: https://github.com/apache/flink-cdc/blob/master/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java#L95 Out

[jira] [Created] (FLINK-37909) Flink CDC source connector for mongodb repeatedly failing in streaming mode with ChangeStreamHistoryLost error

Sachin Mittal created FLINK-37909: - Summary: Flink CDC source connector for mongodb repeatedly failing in streaming mode with ChangeStreamHistoryLost error Key: FLINK-37909 URL: https://issues.apache.org/jira