Re: flink cdc postgres connector 1.1 - heartbeat.interval.ms - WAL consumption

2021-04-08 Thread bat man
Thanks Till. Hi Jark, Any inputs, going through the code of 1.1 and 1.3 in the meantime. Thanks, Hemant On Thu, Apr 8, 2021 at 3:52 PM Till Rohrmann wrote: > Hi Hemant, > > I am pulling in Jark who is most familiar with Flink's cdc connector. He > might also be able to tell whether the fix ca

Re: flink cdc postgres connector 1.1 - heartbeat.interval.ms - WAL consumption

2021-04-08 Thread Till Rohrmann
Hi Hemant, I am pulling in Jark who is most familiar with Flink's cdc connector. He might also be able to tell whether the fix can be backported. Cheers, Till On Thu, Apr 8, 2021 at 10:42 AM bat man wrote: > Anyone who has faced similar issues with cdc with Postgres. > > I see the restart_lsn

Re: flink cdc postgres connector 1.1 - heartbeat.interval.ms - WAL consumption

2021-04-08 Thread bat man
Anyone who has faced similar issues with cdc with Postgres. I see the restart_lsn and confirmed_flush_lsn constant since the snapshot replication records were streamed even though I have tried inserting a record in the whitelisted table. select * from pg_replication_slots; slot_name | plugin