From 637456213773f61803796e8e2594e90fdb89a4a7 Mon Sep 17 00:00:00 2001 From: Mohammad Mahdi Date: Mon, 29 Sep 2025 16:37:15 +0330 Subject: [PATCH] Improved logging --- internal/mqtt/mqtt.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/mqtt/mqtt.go b/internal/mqtt/mqtt.go index e24daa8..c805390 100644 --- a/internal/mqtt/mqtt.go +++ b/internal/mqtt/mqtt.go @@ -50,6 +50,7 @@ func NewClient(logger *zap.Logger, config *config.Config, csvHelper *csv.Helper) } func StartListening(logger *zap.Logger, config *config.Config, client mqtt.Client) { + logger.Info("Subscribing to", zap.Int("topics", len(config.Topics))) for _, topic := range config.Topics { if token := client.Subscribe(topic, 0, nil); token.Wait() && token.Error() != nil { logger.Error("error subscribing to topic", zap.String("topic", topic), zap.Error(token.Error()))