From 788f8626c46e0570e1e23d1c540e724e9b2ea83e Mon Sep 17 00:00:00 2001 From: Kanthi Subramanian Date: Wed, 22 Jan 2025 13:27:59 -0500 Subject: [PATCH] #380 - Added configuration settings to prevent freeze of debezium loop. --- sink-connector-lightweight/docker/config.yml | 7 +++++++ sink-connector-lightweight/docker/config_postgres.yml | 10 +++++++++- 2 files changed, 16 insertions(+), 1 deletion(-) diff --git a/sink-connector-lightweight/docker/config.yml b/sink-connector-lightweight/docker/config.yml index 554b2a339..a9738f1aa 100644 --- a/sink-connector-lightweight/docker/config.yml +++ b/sink-connector-lightweight/docker/config.yml @@ -183,3 +183,10 @@ metrics.enable: "true" # to reduce slow startup when replicating dbs with large number of tables #schema.history.internal.store.only.captured.tables.ddl: "true" #schema.history.internal.store.only.captured.databases.ddl: "true" + +# Required for fixing bug with freeze in debezium loop. +use.nongraceful.disconnect: "true" +database.keep.alive.interval.`ms: "30000" #Send keepalive every 30 seconds +database.connection.reconnect.backoff.ms: "1000" +database.connection.reconnect.backoff.max.ms: "10000" +database.ssl.mode: "disabled" \ No newline at end of file diff --git a/sink-connector-lightweight/docker/config_postgres.yml b/sink-connector-lightweight/docker/config_postgres.yml index e3ec71e05..d5178c43b 100644 --- a/sink-connector-lightweight/docker/config_postgres.yml +++ b/sink-connector-lightweight/docker/config_postgres.yml @@ -125,4 +125,12 @@ SELECT toDateTime(fromUnixTimestamp(toInt32(JSONExtractUInt(offset_val, 'ts_usec') / 1000000)), 'UTC') AS utc_time, fromUnixTimestamp(toInt32(JSONExtractUInt(offset_val, 'ts_usec') / 1000000)) AS local_time FROM altinity_sink_connector.replica_source_info -SETTINGS final = 1" \ No newline at end of file +SETTINGS final = 1" + + +# Required for fixing bug with freeze in debezium loop. +use.nongraceful.disconnect: "true" +database.keep.alive.interval.`ms: "30000" #Send keepalive every 30 seconds +database.connection.reconnect.backoff.ms: "1000" +database.connection.reconnect.backoff.max.ms: "10000" +database.ssl.mode: "disabled" \ No newline at end of file