From 45d3723107082a4c628e32ead485a0f930d799e2 Mon Sep 17 00:00:00 2001
From: Jiwei Guo <technoboy@apache.org>
Date: Tue, 2 Jun 2026 16:38:30 +0800
Subject: [PATCH] Change error log to warn

---
 .../mqtt/common/AbstractCommonProtocolMethodProcessor.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/mqtt-common/src/main/java/io/streamnative/pulsar/handlers/mqtt/common/AbstractCommonProtocolMethodProcessor.java b/mqtt-common/src/main/java/io/streamnative/pulsar/handlers/mqtt/common/AbstractCommonProtocolMethodProcessor.java
index 176b789b4..19dcc686b 100644
--- a/mqtt-common/src/main/java/io/streamnative/pulsar/handlers/mqtt/common/AbstractCommonProtocolMethodProcessor.java
+++ b/mqtt-common/src/main/java/io/streamnative/pulsar/handlers/mqtt/common/AbstractCommonProtocolMethodProcessor.java
@@ -130,7 +130,7 @@ public void processConnect(MqttAdapterMessage adapter) {
             authResult = authenticationService.authenticate(adapter.fromProxy(), session, connectMessage);
             if (authResult.isFailed()) {
                 MqttMessage mqttMessage = MqttConnectAck.errorBuilder().authFail(protocolVersion);
-                log.error("[CONNECT] Invalid or incorrect authentication. CId={}, username={}", clientId, username);
+                log.warn("[CONNECT] Invalid or incorrect authentication. CId={}, username={}", clientId, username);
                 adapter.setMqttMessage(mqttMessage);
                 channel.writeAndFlush(adapter);
                 if (!adapter.fromProxy()) {