|
|
|
@@ -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 |
|
|
|
|