When to use scan.incremental.snapshot.enabled

2024-08-18 Thread Sachin Mittal
Hi, I am using mongodb cdc connector version 3.1.1 I am connecting to mongodb atlas, which uses mongodb version 7.0. In the cdc connector I find a property: scan.incremental.snapshot.enabled with default as false. I wanted to know in what cases we should set this as true and what does this prope

Re: Flink filesystem connector with regex support

2024-08-18 Thread Feng Jin
Hi Amogh You can test the code below: ```java FileSource.forRecordStreamFormat(csvFormat, new Path("file:///tmp/test")) .setFileEnumerator(() -> new NonSplittingRecursiveEnumerator(path -> path.getName().endsWith(".csv"))) .build(); ``` Best, Feng On Sat, Aug 17, 2024 at 4:41 AM amogh joshi