src/main/java/org/springblade/binlog/constant/BinLogConstants.java
@@ -42,7 +42,8 @@ public static final int consumerThreads = 5; public static final long queueSleep = 1000; // public static final long queueSleep = 1000; public static final long queueSleep = 200; }