Skip to content

Commit

Permalink
Use topic.heartbeat.prefix instead of the old heartbeat.topics.prefix
Browse files Browse the repository at this point in the history
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.
  • Loading branch information
josejulio committed Mar 28, 2024
1 parent c710f42 commit f8a5e52
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion deploy/connect-msk.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion deploy/connect.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion event-streams/connector.json
Original file line number Diff line number Diff line change
Expand Up @@ -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();"
}
}
2 changes: 1 addition & 1 deletion examples/connector-local.json
Original file line number Diff line number Diff line change
Expand Up @@ -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();"
}
}

0 comments on commit f8a5e52

Please sign in to comment.