diff --git a/src/MqttPlugin.cpp b/src/MqttPlugin.cpp
index fdbc0e2..a505053 100644
--- a/src/MqttPlugin.cpp
+++ b/src/MqttPlugin.cpp
@@ -55,7 +55,7 @@ void MqttPlugin::connect()
 void MqttPlugin::upstreamHandler(String topic, String msg)
 {
     // publish message on remote queue
-    PRINT_MSG(Serial, "MQTT", String("upstream: " + msg).c_str());
+    PRINT_MSG(Serial, "MQTT", String("publish remote: " + topic).c_str());
     client->publish((String(mqttConfig.outTopicRoot) + topic).c_str(), msg.c_str());
 }
 
@@ -72,6 +72,5 @@ void MqttPlugin::downstreamHandler(char *topic, uint8_t *payload, unsigned int l
     String localTopic = String(topic).substring(topicRootLength);
     publish(localTopic, msg);
 
-    PRINT_MSG(Serial, "MQTT", (String(topic) + " " + msg).c_str());
     PRINT_MSG(Serial, "MQTT", (String("publish local: ") + localTopic).c_str());
 }