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