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 index cab9bd1d2..9cec6ecc6 100644 --- 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 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()