src/main/java/com/duxinglangzi/canal/starter/listener/ApplicationReadyListener.java
@@ -7,7 +7,6 @@ /** * @author wuqiong 2022/4/16 * @description */ public class ApplicationReadyListener implements ApplicationListener<ApplicationReadyEvent>{ @@ -15,6 +14,7 @@ @Override public void onApplicationEvent(ApplicationReadyEvent event) { // 确保程序启动之后,再放行所有的 canal transponder if (!START_LISTENER_CONTAINER.get()) START_LISTENER_CONTAINER.set(true); } }