Fix log key ("c.Topic" -> "topic")

rabbitmq · Aug 19, 2024 · 4aeb8b4 · 4aeb8b4
1 parent 1fe309d
commit 4aeb8b4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/mqtt_client/consumer.go b/pkg/mqtt_client/consumer.go
@@ -87,7 +87,7 @@ func (c MqttConsumer) Start(ctx context.Context, subscribed chan bool) {
 	if token.Error() != nil {
 		log.Error("failed to subscribe", "consumerId", c.Id, "error", token.Error())
 	}
-	log.Info("consumer started", "consumerId", c.Id, "c.Topic", c.Topic)
+	log.Info("consumer started", "consumerId", c.Id, "topic", c.Topic)
 
 	// TODO: currently we can consume more than ConsumerCount messages
 	for msgsReceived < c.Config.ConsumeCount {