diff --git a/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/ConsoleMessageCollector.java b/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/ConsoleMessageCollector.java
index 930f2d0c..bceb48a1 100644
--- a/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/ConsoleMessageCollector.java
+++ b/mybatis-flex-core/src/main/java/com/mybatisflex/core/audit/ConsoleMessageCollector.java
@@ -26,18 +26,6 @@ public class ConsoleMessageCollector implements MessageCollector {
         }
     };
 
-    private SqlDebugExtPrinter extPrinter = (sql, dsName, tookTimeMillis) -> {
-        StringBuilder buffer = new StringBuilder();
-        buffer.append("Flex exec");
-        buffer.append("dsName >>> ").append(dsName);
-        if (tookTimeMillis != null) {
-            buffer.append(" sql took ").append(tookTimeMillis).append(" ms >>>  ").append(sql);
-        } else {
-            buffer.append(" sql >>> ").append(sql);
-        }
-        System.out.println(buffer);
-    };
-
     public ConsoleMessageCollector() {
     }
 
@@ -45,18 +33,9 @@ public class ConsoleMessageCollector implements MessageCollector {
         this.printer = printer;
     }
 
-
-    public ConsoleMessageCollector(SqlDebugExtPrinter printer) {
-        this.extPrinter = printer;
-    }
-
     @Override
     public void collect(AuditMessage message) {
-        if (message.getDsName() == null) {
-            printer.print(message.getFullSql(), message.getElapsedTime());
-        } else {
-            extPrinter.print(message.getFullSql(), message.getDsName(), message.getElapsedTime());
-        }
+        printer.print(message.getFullSql(), message.getElapsedTime());
     }
 
     public interface SqlDebugPrinter {
@@ -65,11 +44,4 @@ public class ConsoleMessageCollector implements MessageCollector {
 
     }
 
-
-    public interface SqlDebugExtPrinter {
-
-        void print(String sql, String dsName, Long tookTimeMillis);
-
-    }
-
 }