From 5ddf349c4f6c2af8c54b2302d727248a2e07fd28 Mon Sep 17 00:00:00 2001 From: lxy <237809796@qq.com> Date: Sat, 10 Oct 2020 16:09:31 +0800 Subject: [PATCH] . --- conf/kafak.properties | 5 ++++- src/com/zdemo/AbstractConsumer.java | 2 ++ 2 files changed, 6 insertions(+), 1 deletion(-) 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; }