From f8a5e52287dd445992e9c1450bc246e3649740ad Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Josejulio=20Mart=C3=ADnez?= Date: Thu, 28 Mar 2024 06:56:09 -0600 Subject: [PATCH] Use topic.heartbeat.prefix instead of the old heartbeat.topics.prefix 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. --- deploy/connect-msk.yaml | 2 +- deploy/connect.yaml | 2 +- event-streams/connector.json | 2 +- examples/connector-local.json | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/deploy/connect-msk.yaml b/deploy/connect-msk.yaml index 1aae18db..94578346 100644 --- 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 index 04b050e1..e15353c8 100644 --- 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 index 5be43e4b..ebfed618 100644 --- 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 index dd17de6b..2b7be921 100644 --- 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();" } }