Re: Mongo flink CDC connector not reading from the source

This worked. Thanks On Sat, 17 Aug 2024 at 6:02 PM, Jiabao Sun wrote: > Hi Sachin, > > The 'collectionList' needs to be filled with fully qualified names. > > For example, > database: test_db > collection: test_collection > > MongoDBSource.builder() > .hosts(HOSTNAME) > .scheme(SCHEM

Re: Mongo flink CDC connector not reading from the source

Hi Sachin, The 'collectionList' needs to be filled with fully qualified names. For example, database: test_db collection: test_collection MongoDBSource.builder() .hosts(HOSTNAME) .scheme(SCHEME) .databaseList("test_db") .collectionList("test_db.test_collection") ... Bes

Mongo flink CDC connector not reading from the source

Hi, I have configured a MongoDB CDC source as : MongoDBSource.builder() .hosts(HOSTNAME) .scheme(SCHEME) .databaseList(MONGO_DB) .collectionList(collectionName) .username(USERNAME) .password(PASSWORD) .startupOptions(StartupOptions.initial()) .batchSize(2048) .d