From da99f4cfb68b883be6a3caaeed5431edd3d6ef15 Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" <41898282+github-actions[bot]@users.noreply.github.com> Date: Mon, 18 Nov 2024 14:06:36 +0800 Subject: [PATCH] fix(pg-cdc): write transactional WAL message as heartbeat action (#19385) (#19392) Signed-off-by: Richard Chien Co-authored-by: StrikeW Co-authored-by: Richard Chien --- .../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 c36b62a7aa531..351287f664e2d 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 @@ -18,9 +18,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}