rm log

dbsyncer-connector/dbsyncer-connector-mysql/src/main/java/org/dbsyncer/connector/mysql/cdc/MySQLListener.java

@@ -36,7 +36,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.util.Assert;
 
-import java.time.Instant;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -173,14 +172,11 @@ public class MySQLListener extends AbstractDatabaseListener {
     private void trySendEvent(ChangedEvent event){
         try {
             // 如果消费事件失败，重试
-            long now = Instant.now().toEpochMilli();
-            boolean isReTry = false;
             while (client.isConnected()){
                 try {
                     sendChangedEvent(event);
                     break;
                 } catch (QueueOverflowException e) {
-                    isReTry = true;
                     try {
                         TimeUnit.MILLISECONDS.sleep(1);
                     } catch (InterruptedException ex) {
@@ -188,9 +184,6 @@ public class MySQLListener extends AbstractDatabaseListener {
                     }
                 }
             }
-            if (isReTry) {
-                logger.info("重试耗时：{}ms", Instant.now().toEpochMilli() - now);
-            }
         } catch (Exception e) {
             logger.error(e.getMessage(), e);
         }

dbsyncer-connector/dbsyncer-connector-mysql/src/main/java/org/dbsyncer/connector/mysql/storage/MySQLStorageService.java

@@ -197,7 +197,7 @@ public class MySQLStorageService extends AbstractStorageService {
     }
 
     private Executor getExecutor(StorageEnum type, String sharding) {
-        return tables.computeIfAbsent(sharding, (table) -> {
+        return tables.computeIfAbsent(sharding, table -> {
             Executor executor = tables.get(type.getType());
             if (executor == null) {
                 throw new NullExecutorException("未知的存储类型");

dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/cdc/OracleListener.java

@@ -31,7 +31,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.sql.SQLException;
-import java.time.Instant;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
@@ -86,14 +85,11 @@ public class OracleListener extends AbstractDatabaseListener {
     private void trySendEvent(ChangedEvent event) {
         try {
             // 如果消费事件失败，重试
-            long now = Instant.now().toEpochMilli();
-            boolean isReTry = false;
             while (logMiner.isConnected()) {
                 try {
                     sendChangedEvent(event);
                     break;
                 } catch (QueueOverflowException e) {
-                    isReTry = true;
                     try {
                         TimeUnit.MILLISECONDS.sleep(1);
                     } catch (InterruptedException ex) {
@@ -101,9 +97,6 @@ public class OracleListener extends AbstractDatabaseListener {
                     }
                 }
             }
-            if (isReTry) {
-                logger.info("重试耗时：{}ms", Instant.now().toEpochMilli() - now);
-            }
         } catch (Exception e) {
             logger.error(e.getMessage(), e);
         }