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();" } }