Re: Cdc on HA postgresql

Hi, Steffen Currently, PostgreSQL database not support this feather. Although slave PostgreSQL can also provide logical replication since PG 16+, the replication slot is not existed when checkout database. If you want to use postgres cdc with HA setup, you have to create slots at all the instanc

Re: Problems with multiple sinks using postgres-cdc connector

-> process1 -> process2 -> sink2 > `--> sink1 > > I get the errors described, where it appears that a second process is > created that attempts to use the current slot twice. > > On Mon, Jun 17, 2024 at 1:58 AM Hongshun Wang > wrote: > >> Hi David, >> >

Re: Problems with multiple sinks using postgres-cdc connector

Hi David, > When I add this second sink, the postgres-cdc connector appears to add a second reader from the replication log, but with the same slot name. I don't understand what you mean by adding a second sink. Do they share the same source, or does each have a separate pipeline? If the former on

Re: problem with the heartbeat interval feature

/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceReaderWithCommit.java#L93 On Sat, May 18, 2024 at 12:34 AM Thomas Peyric wrote: > thanks Hongshun for your response ! > > Le ven. 17 mai 2024 à 07:51, Hongshun Wang a > écrit : > >>

Re: problem with the heartbeat interval feature

Hi Thomas, In debezium dos says: For the connector to detect and process events from a heartbeat table, you must add the table to the PostgreSQL publication specified by the publication.name