diff --git a/backend/services/scripts/debezium/auth-outbox-connector.json b/backend/services/scripts/debezium/auth-outbox-connector.json
index 0fa95a94..a57d91fb 100644
--- a/backend/services/scripts/debezium/auth-outbox-connector.json
+++ b/backend/services/scripts/debezium/auth-outbox-connector.json
@@ -35,6 +35,7 @@
     "transforms.route.replacement": "cdc.auth.outbox",
 
     "heartbeat.interval.ms": "10000",
+    "heartbeat.action.query": "SELECT pg_logical_emit_message(false, 'heartbeat', now()::varchar)",
 
     "snapshot.mode": "initial",
 
diff --git a/backend/services/scripts/debezium/contribution-outbox-connector.json b/backend/services/scripts/debezium/contribution-outbox-connector.json
index c154d66f..2b0c3357 100644
--- a/backend/services/scripts/debezium/contribution-outbox-connector.json
+++ b/backend/services/scripts/debezium/contribution-outbox-connector.json
@@ -35,6 +35,7 @@
     "transforms.route.replacement": "cdc.contribution.outbox",
 
     "heartbeat.interval.ms": "10000",
+    "heartbeat.action.query": "SELECT pg_logical_emit_message(false, 'heartbeat', now()::varchar)",
 
     "snapshot.mode": "initial",
 
diff --git a/backend/services/scripts/debezium/mining-outbox-connector.json b/backend/services/scripts/debezium/mining-outbox-connector.json
index 20b5e502..106a2ea7 100644
--- a/backend/services/scripts/debezium/mining-outbox-connector.json
+++ b/backend/services/scripts/debezium/mining-outbox-connector.json
@@ -35,6 +35,7 @@
     "transforms.route.replacement": "cdc.mining.outbox",
 
     "heartbeat.interval.ms": "10000",
+    "heartbeat.action.query": "SELECT pg_logical_emit_message(false, 'heartbeat', now()::varchar)",
 
     "snapshot.mode": "initial",
 
diff --git a/backend/services/scripts/debezium/mining-wallet-outbox-connector.json b/backend/services/scripts/debezium/mining-wallet-outbox-connector.json
index 406885d8..4bc44c64 100644
--- a/backend/services/scripts/debezium/mining-wallet-outbox-connector.json
+++ b/backend/services/scripts/debezium/mining-wallet-outbox-connector.json
@@ -35,6 +35,7 @@
     "transforms.route.replacement": "cdc.mining-wallet.outbox",
 
     "heartbeat.interval.ms": "10000",
+    "heartbeat.action.query": "SELECT pg_logical_emit_message(false, 'heartbeat', now()::varchar)",
 
     "snapshot.mode": "initial",
 
diff --git a/backend/services/scripts/debezium/trading-outbox-connector.json b/backend/services/scripts/debezium/trading-outbox-connector.json
index 316ee8d7..17b80316 100644
--- a/backend/services/scripts/debezium/trading-outbox-connector.json
+++ b/backend/services/scripts/debezium/trading-outbox-connector.json
@@ -35,6 +35,7 @@
     "transforms.route.replacement": "cdc.trading.outbox",
 
     "heartbeat.interval.ms": "10000",
+    "heartbeat.action.query": "SELECT pg_logical_emit_message(false, 'heartbeat', now()::varchar)",
 
     "snapshot.mode": "initial",