diff --git a/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java b/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java
index 8e926f21e..5054f3631 100644
--- a/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java
+++ b/r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/client/ReactorNettyClient.java
@@ -379,17 +379,17 @@ public void error(Throwable e) {
 
         @Override
         public void next(ServerMessage message) {
-            if (message instanceof WarningMessage) {
-                int warnings = ((WarningMessage) message).getWarnings();
-                if (warnings == 0) {
-                    if (DEBUG_ENABLED) {
+            if (DEBUG_ENABLED) {
+                if (message instanceof WarningMessage) {
+                    final int warnings = ((WarningMessage) message).getWarnings();
+                    if (warnings == 0) {
                         logger.debug("Response: {}", message);
+                    } else {
+                        logger.debug("Response: {}, reports {} warning(s)", message, warnings);
                     }
-                } else if (INFO_ENABLED) {
-                    logger.info("Response: {}, reports {} warning(s)", message, warnings);
+                } else {
+                    logger.debug("Response: {}", message);
                 }
-            } else if (DEBUG_ENABLED) {
-                logger.debug("Response: {}", message);
             }
 
             responseProcessor.emitNext(message, EmitFailureHandler.FAIL_FAST);