diff --git a/src/emqttd_client.erl b/src/emqttd_client.erl
index bffb9232f..f78422ac6 100644
--- a/src/emqttd_client.erl
+++ b/src/emqttd_client.erl
@@ -110,9 +110,9 @@ handle_info(timeout, State) ->
     stop({shutdown, timeout}, State);
     
 handle_info({stop, duplicate_id, _NewPid}, State=#state{proto_state = ProtoState,
-                                                        conn_name=ConnName}) ->
-    lager:error("Shutdown for duplicate clientid: ~s, conn:~s", 
-                [emqttd_protocol:clientid(ProtoState), ConnName]), 
+                                                        conn_name   = ConnName}) ->
+    lager:warning("Shutdown for duplicate clientid: ~s, conn:~s",
+                  [emqttd_protocol:clientid(ProtoState), ConnName]),
     stop({shutdown, duplicate_id}, State);
 
 handle_info({deliver, Message}, State = #state{proto_state = ProtoState}) ->
diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl
index db68b368d..9a29ce5da 100644
--- a/src/emqttd_session.erl
+++ b/src/emqttd_session.erl
@@ -571,7 +571,7 @@ kick(_ClientId, _ClientPid, undefined) ->
 kick(_ClientId, ClientPid, ClientPid) ->
             ok;
 kick(ClientId, ClientPid, OldClientPid) ->
-    lager:error("Session '~s' is duplicated: pid=~p, oldpid=~p", [ClientId, ClientPid, OldClientPid]),
+    lager:warning("Session '~s' is duplicated: pid=~p, oldpid=~p", [ClientId, ClientPid, OldClientPid]),
     unlink(OldClientPid),
     OldClientPid ! {stop, duplicate_id, ClientPid}.