diff --git a/broker/src/main/java/cn/wildfirechat/server/ThreadPoolExecutorWrapper.java b/broker/src/main/java/cn/wildfirechat/server/ThreadPoolExecutorWrapper.java
index cdaf10fa..cffec2bd 100644
--- a/broker/src/main/java/cn/wildfirechat/server/ThreadPoolExecutorWrapper.java
+++ b/broker/src/main/java/cn/wildfirechat/server/ThreadPoolExecutorWrapper.java
@@ -30,14 +30,14 @@ public class ThreadPoolExecutorWrapper {
 
     public void execute(Runnable task) {
         int startCount = runCounter.incrementAndGet();
-        LOG.info("Submit task and current taskcount {}", startCount);
+        LOG.debug("Submit task and current task count {}", startCount);
         final long startTime = System.currentTimeMillis();
         executor.execute(() -> {
             try {
                 task.run();
             } finally {
                 int endCount = runCounter.decrementAndGet();
-                LOG.info("Finish task and current taskcount {} use time {}", endCount, System.currentTimeMillis()-startTime);
+                LOG.debug("Finish task and current task count {} use time {}", endCount, System.currentTimeMillis()-startTime);
             }
         });
     }
diff --git a/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java b/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java
index 0d0b9fc6..ae0b824b 100755
--- a/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java
+++ b/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java
@@ -525,7 +525,7 @@ public class MemorySessionStore implements ISessionsStore {
 
     @Override
     public void cleanSession(String clientID) {
-        LOG.error("Fooooooooo <{}>", clientID);
+        LOG.info("Fooooooooo <{}>", clientID);
 
         Session session = sessions.get(clientID);
         if (session == null) {