From 20273a7d88b5d09895fbb37107b0efb8d5301bf7 Mon Sep 17 00:00:00 2001
From: Qiang Zhao <mattisonchao@apache.org>
Date: Thu, 27 Jul 2023 18:25:24 +0800
Subject: [PATCH] Improve log to avoid too much error (#1049)

---
 .../java/io/streamnative/pulsar/handlers/mqtt/Connection.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 b9384a93f..ed68a0e57 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
@@ -136,7 +136,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());