.

conf/kafak.properties

@@ -1,5 +1,8 @@
 # Producer
-bootstrap.servers=47.111.150.118:6062
+#bootstrap.servers=47.111.150.118:6062
+#bootstrap.servers=121.196.17.55:6062
+bootstrap.servers=39.108.56.246:9092
+#bootstrap.servers=122.112.180.156:6062
 acks=all
 retries=0
 batch.size=16384

src/com/zdemo/AbstractConsumer.java

@@ -14,6 +14,8 @@ public abstract class AbstractConsumer implements IConsumer {
 
     public final Map<String, EventType> eventMap = new HashMap<>();
 
+    public abstract String getGroupid();
+
     public boolean preInit() {
         return true;
     }