diff --git a/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java b/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java index a6b95f3..b41f5e6 100644 --- a/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java +++ b/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java @@ -10,6 +10,7 @@ public class AustinFlinkConstant { * Kafka 配置信息 * TODO 使用前配置kafka broker ip:port * (真实网络ip,这里不能用配置的hosts,看语雀文档得到真实ip) + * (如果想要自己监听到所有的消息,改掉groupId) */ public static final String GROUP_ID = "austinLogGroup"; public static final String TOPIC_NAME = "austinTraceLog";