.

src/com/zdemo/AbstractConsumer.java

@@ -64,10 +64,10 @@ public abstract class AbstractConsumer implements IConsumer {
             for (String x : topic.split(",")) {
                 subscribe(x, typeToken, consumer);
             }
+        } else {
+            eventMap.put(topic, EventType.of(topic, typeToken, consumer));
+            subscribe(topic);
         }
-
-        eventMap.put(topic, EventType.of(topic, typeToken, consumer));
-        subscribe(topic);
     }
 
 }

src/com/zdemo/kafak/KafakConsumer.java

@@ -30,8 +30,6 @@ public abstract class KafakConsumer extends AbstractConsumer implements IConsume
     @Resource(name = "APP_HOME")
     protected File APP_HOME;
 
-    public abstract String getGroupid();
-
     private final LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<>();
 
     @Override

src/com/zdemo/zhub/ZHubClient.java

@@ -25,7 +25,7 @@ import java.util.logging.Logger;
 
 public abstract class ZHubClient extends AbstractConsumer implements IConsumer, IProducer, Service {
 
-    Logger logger = Logger.getLogger(ZHubClient.class.getSimpleName());
+    public Logger logger = Logger.getLogger(ZHubClient.class.getSimpleName());
 
     @Resource(name = "property.zhub.host")
     private String host = "127.0.0.1";

test/com/zdemo/test/MyConsumer.java

@@ -9,7 +9,7 @@ public class MyConsumer extends ZHubClient {
     }
 
     @Override
-    public boolean preInit() {
+    protected boolean preInit() {
         return true;
     }
 }