From a3eef0851096d6275e43cfc9655a523f06845f50 Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer <code@pcvolkmer.de>
Date: Fri, 29 Aug 2025 14:13:17 +0200
Subject: [PATCH] feat: log error if response could not be sent

---
 src/main.rs | 16 +++++++++++-----
 1 file changed, 11 insertions(+), 5 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index c8cf9d6..a25ab2d 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -156,14 +156,13 @@ async fn main() -> Result<(), Box<dyn Error>> {
                                     )
                                     .unwrap_or(json!({})),
                                 };
-
-                                let payload = serde_json::to_string(&response_payload)?;
+                                let response_payload = serde_json::to_string(&response_payload)?;
 
                                 let response_record = FutureRecord::to(&CONFIG.response_topic)
                                     .key(key)
-                                    .payload(&payload);
+                                    .payload(&response_payload);
 
-                                let _ = if let Some(headers) = msg.headers() {
+                                match if let Some(headers) = msg.headers() {
                                     producer
                                         .send(
                                             response_record.headers(headers.detach()),
@@ -172,7 +171,14 @@ async fn main() -> Result<(), Box<dyn Error>> {
                                         .await
                                 } else {
                                     producer.send(response_record, Duration::from_secs(1)).await
-                                };
+                                } {
+                                    Ok(_) => {
+                                        info!("Response for '{request_id}' sent successfully");
+                                    }
+                                    Err((err, _)) => {
+                                        error!("Could not send response for '{request_id}': {err}");
+                                    }
+                                }
 
                                 if response.status_code == 200 || response.status_code == 201 || response.status_code == 400 || response.status_code == 422 {
                                     consumer