diff --git a/pkg/mqtt_client/consumer.go b/pkg/mqtt_client/consumer.go
index c1a2002..6eba2e7 100644
--- 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 {