diff --git a/mqtt-impl/src/main/java/io/streamnative/pulsar/handlers/mqtt/Connection.java b/mqtt-impl/src/main/java/io/streamnative/pulsar/handlers/mqtt/Connection.java
index fdad2367f..f081ef54b 100644
--- a/mqtt-impl/src/main/java/io/streamnative/pulsar/handlers/mqtt/Connection.java
+++ b/mqtt-impl/src/main/java/io/streamnative/pulsar/handlers/mqtt/Connection.java
@@ -131,7 +131,8 @@ private void addIdleStateHandler() {
      */
     public CompletableFuture<Void> send(MqttMessage mqttMessage) {
         if (!channel.isActive()) {
-            log.error("send mqttMessage : {} failed due to channel is inactive.", mqttMessage);
+            log.warn("send mqttMessage : {} failed due to channel is inactive.",
+                    mqttMessage.fixedHeader().messageType());
             return FutureUtils.completableFuture(channel.newFailedFuture(channelInactiveException));
         }
         MqttAdapterMessage mqttAdapterMessage = new MqttAdapterMessage(clientId, mqttMessage, isFromProxy());