From 5fb6f698d7bcee376e420bd0f35d46a437be80d6 Mon Sep 17 00:00:00 2001 From: Eric Fu Date: Fri, 12 Apr 2024 16:53:22 +0800 Subject: [PATCH] fix(direct cdc): use `time.precision.mode=connect` (#16119) --- .../src/main/resources/debezium.properties | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/java/connector-node/risingwave-connector-service/src/main/resources/debezium.properties b/java/connector-node/risingwave-connector-service/src/main/resources/debezium.properties index 754cade321f97..4d85e1b98c78f 100644 --- a/java/connector-node/risingwave-connector-service/src/main/resources/debezium.properties +++ b/java/connector-node/risingwave-connector-service/src/main/resources/debezium.properties @@ -11,7 +11,7 @@ decimal.handling.mode=${debezium.decimal.handling.mode:-string} interval.handling.mode=string max.batch.size=${debezium.max.batch.size:-1024} max.queue.size=${debezium.max.queue.size:-8192} -time.precision.mode=adaptive_time_microseconds +time.precision.mode=connect # Quoted from the debezium document: # > Your application should always properly stop the engine to ensure graceful and complete # > shutdown and that each source record is sent to the application exactly one time.