From 5042293be92cb13b5446a02e26701ed7677f7699 Mon Sep 17 00:00:00 2001 From: StrikeW Date: Wed, 31 Jan 2024 17:02:23 +0800 Subject: [PATCH] enable cdc transaction by default --- .../src/main/resources/mysql.properties | 3 ++- .../src/main/resources/postgres.properties | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/java/connector-node/risingwave-connector-service/src/main/resources/mysql.properties b/java/connector-node/risingwave-connector-service/src/main/resources/mysql.properties index 4c74b48bbf174..8b1d571082f6e 100644 --- a/java/connector-node/risingwave-connector-service/src/main/resources/mysql.properties +++ b/java/connector-node/risingwave-connector-service/src/main/resources/mysql.properties @@ -22,4 +22,5 @@ heartbeat.interval.ms=${debezium.heartbeat.interval.ms:-60000} # In sharing cdc 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}.${table.name:-RW_CDC_Sharing} -provide.transaction.metadata=${transactional:-false} +# Enable transaction metadata by default +provide.transaction.metadata=${transactional:-true} 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 7f9785b7a34b1..8d0284d03892e 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 @@ -20,4 +20,5 @@ heartbeat.interval.ms=${debezium.heartbeat.interval.ms:-300000} # 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} -provide.transaction.metadata=${transactional:-false} +# Enable transaction metadata by default +provide.transaction.metadata=${transactional:-true}