diff --git a/conf/kafak.properties b/conf/kafak.properties index dcb1935..37bcd72 100644 --- a/conf/kafak.properties +++ b/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 diff --git a/src/com/zdemo/AbstractConsumer.java b/src/com/zdemo/AbstractConsumer.java index ac6aeb0..6211d68 100644 --- a/src/com/zdemo/AbstractConsumer.java +++ b/src/com/zdemo/AbstractConsumer.java @@ -14,6 +14,8 @@ public abstract class AbstractConsumer implements IConsumer { public final Map eventMap = new HashMap<>(); + public abstract String getGroupid(); + public boolean preInit() { return true; }