mirror of
https://github.com/hexolan/stocklet.git
synced 2026-03-26 11:41:18 +00:00
fix: ineffective err assignment
This commit is contained in:
@@ -49,11 +49,15 @@ func applyPostgresOutbox(cfg *InitConfig, conf *config.PostgresConfig) {
|
|||||||
|
|
||||||
url := cfg.DebeziumHost + "/connectors/" + cfg.ServiceName + "-outbox/config"
|
url := cfg.DebeziumHost + "/connectors/" + cfg.ServiceName + "-outbox/config"
|
||||||
log.Info().Str("url", url).Msg("debezium url")
|
log.Info().Str("url", url).Msg("debezium url")
|
||||||
|
|
||||||
req, err := http.NewRequest(
|
req, err := http.NewRequest(
|
||||||
"PUT",
|
"PUT",
|
||||||
url,
|
url,
|
||||||
bytes.NewReader(payloadB),
|
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("Accept", "application/json")
|
||||||
req.Header.Set("Content-Type", "application/json")
|
req.Header.Set("Content-Type", "application/json")
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user