新增失败回调

core/src/main/java/com/tbyf/cdcengine2/core/AbstractCdcEngine.java

@@ -124,6 +124,10 @@ public abstract class AbstractCdcEngine<T extends AbstractCdcEngine<T>> {
                         if (!success) {
                             logger.error("启动失败, 原因: {}", message, error);
                             stop();
+                            Runnable errorHandler = this.errorHandler;
+                            if (errorHandler != null) {
+                                errorHandler.run();
+                            }
                         }
                     }))
                     .notifying(event -> {
@@ -169,10 +173,7 @@ public abstract class AbstractCdcEngine<T extends AbstractCdcEngine<T>> {
             }
             this.consumerThread = null;
 
-            Runnable errorHandler = this.errorHandler;
-            if (errorHandler != null) {
-                errorHandler.run();
-            }
+
         }
     }