From 0c9c64b377b12432d6756023f35d9b61978adba2 Mon Sep 17 00:00:00 2001
From: Declan Teevan
Date: Thu, 13 Mar 2025 16:21:19 +0000
Subject: [PATCH] fix: ineffective err assignment
---
cmd/service-init/connectors.go | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/cmd/service-init/connectors.go b/cmd/service-init/connectors.go
index 5169c5f..6de4bf3 100644
--- a/cmd/service-init/connectors.go
+++ b/cmd/service-init/connectors.go
@@ -49,11 +49,15 @@ func applyPostgresOutbox(cfg *InitConfig, conf *config.PostgresConfig) {
url := cfg.DebeziumHost + "/connectors/" + cfg.ServiceName + "-outbox/config"
log.Info().Str("url", url).Msg("debezium url")
+
req, err := http.NewRequest(
"PUT",
url,
bytes.NewReader(payloadB),
)
+ if err != nil {
+ log.Panic().Err(err).Msg("debezium connect: failed to prepare request")
+ }
req.Header.Set("Accept", "application/json")
req.Header.Set("Content-Type", "application/json")