Use topic.heartbeat.prefix instead of the old heartbeat.topics.prefix (…

…#359) Should fix some errors we saw on stage where it complains about a topic. Turns out we were using the wrong configuration value and the wrong topic.
RedHatInsights · Mar 28, 2024 · 20e8d1d · 20e8d1d
1 parent c710f42
commit 20e8d1d
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/deploy/connect-msk.yaml b/deploy/connect-msk.yaml
@@ -305,7 +305,7 @@ objects:
         errors.log.include.messages: "true"
 
         heartbeat.interval.ms: 600000
-        heartbeat.topics.prefix: "__debezium-heartbeat-pd"
+        topic.heartbeat.prefix: "__debezium-heartbeat-pd"
         heartbeat.action.query: "INSERT INTO public.runs (id, org_id, recipient, correlation_id, url, service, timeout, created_at, updated_at) VALUES ('98875b33-b37e-4c35-be8b-d74f321bac28', '5318290', '00000000-0000-0000-0000-000000000000', '00000000-0000-0000-0000-000000000000', 'https://redhat.com', 'heartbeat', 3600, NOW(), NOW()) ON CONFLICT(id) DO UPDATE SET updated_at=NOW();"
 
 - apiVersion: apps/v1

diff --git a/deploy/connect.yaml b/deploy/connect.yaml
@@ -298,7 +298,7 @@ objects:
         errors.log.include.messages: "true"
 
         heartbeat.interval.ms: 600000
-        heartbeat.topics.prefix: "__debezium-heartbeat-pd"
+        topic.heartbeat.prefix: "__debezium-heartbeat-pd"
         heartbeat.action.query: "INSERT INTO public.runs (id, org_id, recipient, correlation_id, url, service, timeout, created_at, updated_at) VALUES ('98875b33-b37e-4c35-be8b-d74f321bac28', '5318290', '00000000-0000-0000-0000-000000000000', '00000000-0000-0000-0000-000000000000', 'https://redhat.com', 'heartbeat', 3600, NOW(), NOW()) ON CONFLICT(id) DO UPDATE SET updated_at=NOW();"
 
 - apiVersion: apps/v1

diff --git a/event-streams/connector.json b/event-streams/connector.json
@@ -37,7 +37,7 @@
         "errors.log.include.messages":true,
 
         "heartbeat.interval.ms": 600000,
-        "heartbeat.topics.prefix": "__debezium-heartbeat-pd",
+        "topic.heartbeat.prefix": "__debezium-heartbeat-pd",
         "heartbeat.action.query": "INSERT INTO public.runs (id, org_id, recipient, correlation_id, url, service, timeout, created_at, updated_at) VALUES ('98875b33-b37e-4c35-be8b-d74f321bac28', '5318290', '00000000-0000-0000-0000-000000000000', '00000000-0000-0000-0000-000000000000', 'https://redhat.com', 'heartbeat', 3600, NOW(), NOW()) ON CONFLICT(id) DO UPDATE SET updated_at=NOW();"
     }
 }
diff --git a/examples/connector-local.json b/examples/connector-local.json
@@ -39,7 +39,7 @@
         "errors.log.include.messages":true,
 
         "heartbeat.interval.ms": 60000,
-        "heartbeat.topics.prefix": "__debezium-heartbeat-pd",
+        "topic.heartbeat.prefix": "__debezium-heartbeat-pd",
         "heartbeat.action.query": "INSERT INTO public.runs (id, org_id, recipient, correlation_id, url, service, timeout, created_at, updated_at) VALUES ('98875b33-b37e-4c35-be8b-d74f321bac28', '5318290', '00000000-0000-0000-0000-000000000000', '00000000-0000-0000-0000-000000000000', 'https://redhat.com', 'heartbeat', 3600, NOW(), NOW()) ON CONFLICT(id) DO UPDATE SET updated_at=NOW();"
     }
 }