Improve log to avoid too much error (#1049)

streamnative · Jul 27, 2023 · 138efc3 · 138efc3
1 parent 85ab30f
commit 138efc3
Showing 1 changed file with 2 additions and 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
@@ -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());