diff --git a/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java b/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java
index 1a4d57ab8..e30191e8e 100644
--- a/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java
+++ b/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java
@@ -305,10 +305,10 @@ private void handleClose() {
         STATE_UPDATER.set(this, ST_CLOSED);
 
         if (oldState != ST_CLOSING) {
-            logger.debug("Connection has been closed by peer");
+            logger.warn("Connection unexpectedly closed");
             drainError(ClientExceptions.unexpectedClosed());
         } else {
-            logger.debug("Connection has been closed");
+            logger.debug("Connection closed");
             drainError(ClientExceptions.expectedClosed());
         }
     }