diff --git a/src/com/zdemo/AbstractConsumer.java b/src/com/zdemo/AbstractConsumer.java
index 2793e44..ac6aeb0 100644
--- a/src/com/zdemo/AbstractConsumer.java
+++ b/src/com/zdemo/AbstractConsumer.java
@@ -14,7 +14,8 @@ public abstract class AbstractConsumer implements IConsumer {
 
     public final Map<String, EventType> eventMap = new HashMap<>();
 
-    public void preInit() {
+    public boolean preInit() {
+        return true;
     }
 
     public void addEventType(EventType... eventType) {
diff --git a/src/com/zdemo/IConsumer.java b/src/com/zdemo/IConsumer.java
index 32cdd25..48051be 100644
--- a/src/com/zdemo/IConsumer.java
+++ b/src/com/zdemo/IConsumer.java
@@ -6,7 +6,7 @@ import java.util.Collection;
 import java.util.logging.Logger;
 
 public interface IConsumer<T extends Event> {
-    TypeToken TYPE_TOKEN_STRING = new TypeToken<String>() {
+    TypeToken<String> TYPE_TOKEN_STRING = new TypeToken<String>() {
     };
     TypeToken<Integer> TYPE_TOKEN_INT = new TypeToken<Integer>() {
     };
diff --git a/src/com/zdemo/kafak/KafakConsumer.java b/src/com/zdemo/kafak/KafakConsumer.java
index ea08e2d..3b655c2 100644
--- a/src/com/zdemo/kafak/KafakConsumer.java
+++ b/src/com/zdemo/kafak/KafakConsumer.java
@@ -54,7 +54,9 @@ public abstract class KafakConsumer extends AbstractConsumer implements IConsume
 
     @Override
     public final void init(AnyValue config) {
-        preInit();
+        if (!preInit()) {
+            return;
+        }
         try (FileInputStream fis = new FileInputStream(new File(APP_HOME, "conf/kafak.properties"));) {
             props = new Properties();
             props.load(fis);
diff --git a/test/com/zdemo/test/MyConsumer.java b/test/com/zdemo/test/MyConsumer.java
index 223b400..2daf5b1 100644
--- a/test/com/zdemo/test/MyConsumer.java
+++ b/test/com/zdemo/test/MyConsumer.java
@@ -12,7 +12,7 @@ public class MyConsumer extends KafakConsumer {
     }
 
     @Override
-    public void preInit() {
+    public boolean preInit() {
         addEventType(
                 EventType.of("a1", new TypeToken<Float>() {
                 }, r -> {
@@ -23,5 +23,7 @@ public class MyConsumer extends KafakConsumer {
                     System.out.println("我收到了消息 主题bx 事件：" + str);
                 })
         );
+
+        return true;
     }
 }