From fa99969ebbfbd46476455d7dc33a553aa18ab68a Mon Sep 17 00:00:00 2001 From: StrikeW Date: Thu, 14 Nov 2024 17:41:11 +0800 Subject: [PATCH] fix(pg-cdc): write transactional WAL message as heartbeat action (#19385) --- .../src/main/resources/postgres.properties | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/java/connector-node/risingwave-connector-service/src/main/resources/postgres.properties b/java/connector-node/risingwave-connector-service/src/main/resources/postgres.properties index 89701280b246..3922ad2fdf47 100644 --- a/java/connector-node/risingwave-connector-service/src/main/resources/postgres.properties +++ b/java/connector-node/risingwave-connector-service/src/main/resources/postgres.properties @@ -19,9 +19,9 @@ publication.autocreate.mode=disabled publication.name=${publication.name:-rw_publication} # default heartbeat interval 5 mins heartbeat.interval.ms=${debezium.heartbeat.interval.ms:-300000} -# emit a WAL message to the replication stream +# emit a transactional WAL message to the replication stream # see https://github.com/risingwavelabs/risingwave/issues/16697 for more details -heartbeat.action.query=SELECT pg_logical_emit_message(false, 'heartbeat', now()::varchar) +heartbeat.action.query=SELECT pg_logical_emit_message(true, 'heartbeat', now()::varchar) # In sharing cdc source mode, we will subscribe to multiple tables in the given database, # so here we set ${table.name} to a default value `RW_CDC_Sharing` just for display. name=${hostname}:${port}:${database.name}.${schema.name}.${table.name:-RW_CDC_Sharing}