src/main/java/org/springblade/binlog/constant/BinLogConstants.java
@@ -31,6 +31,15 @@ @Value("${binlog.table}") private String table; @Value("${binlog.from.datasource.url}") private String fromUrl; @Value("${binlog.from.datasource.username}") private String fromUsername; @Value("${binlog.from.datasource.password}") private String fromPassword; public static final int consumerThreads = 5; public static final long queueSleep = 1000;