From edcd09020e7fed0db4171a969759d8704f745fce Mon Sep 17 00:00:00 2001
From: blazSmehov <blaz.smehov@senlab.io>
Date: Thu, 7 May 2026 10:37:50 +0200
Subject: [PATCH] fix: remove sleep and break in mqtt handler, break causes
 silent discards, sleep blocks all subsequent requests

---
 internal/pkg/bridge/handler.go | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/internal/pkg/bridge/handler.go b/internal/pkg/bridge/handler.go
index 9f586b7..1ea2592 100644
--- a/internal/pkg/bridge/handler.go
+++ b/internal/pkg/bridge/handler.go
@@ -5,7 +5,6 @@ import (
 	"encoding/json"
 	"log/slog"
 	"strings"
-	"time"
 
 	"github.com/AFASystems/presence/internal/pkg/common/appcontext"
 	"github.com/AFASystems/presence/internal/pkg/kafkaclient"
@@ -53,8 +52,7 @@ func HandleMQTTMessage(topic string, payload []byte, appState *appcontext.AppSta
 			}
 			if err := kafkaclient.Write(ctx, writer, kafka.Message{Value: encoded}); err != nil {
 				slog.Error("writing to Kafka", "err", err)
-				time.Sleep(1 * time.Second)
-				break
+				continue
 			}
 		}
 		return