Change log level to debug (#1033)

streamnative · Jul 25, 2023 · 726f526 · 726f526
1 parent a440913
commit 726f526
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/mqtt-impl/src/main/java/io/streamnative/pulsar/handlers/mqtt/support/Qos1PublishHandler.java b/mqtt-impl/src/main/java/io/streamnative/pulsar/handlers/mqtt/support/Qos1PublishHandler.java
@@ -73,7 +73,9 @@ public CompletableFuture<Void> publish(Connection connection, MqttAdapterMessage
  }).exceptionally(ex -> {
  Throwable realCause = FutureUtil.unwrapCompletionException(ex);
  if (realCause instanceof MQTTNoMatchingSubscriberException) {
- log.warn("[{}] Write {} to Pulsar topic succeed. But do not have subscriber.", topic, msg);
+ if (log.isDebugEnabled()) {
+ log.debug("[{}] Write {} to Pulsar topic succeed. But do not have subscriber.", topic, msg);
+ }
  MqttAck mqttAck = MqttPubAck.successBuilder(protocolVersion)
  .packetId(packetId)
  .isNoMatchingSubscription()