From bd481fad8012bfffd402e79e812d95ded3ee99ad Mon Sep 17 00:00:00 2001 From: 3y Date: Thu, 7 Jul 2022 20:32:36 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=94=B9=20vip=20=E5=86=99=E5=85=A5?= =?UTF-8?q?=20kafka=20=E5=85=A8=E9=93=BE=E8=B7=AF=E8=BF=BD=E8=B8=AA?= =?UTF-8?q?=E7=9A=84topic?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/java3y/austin/stream/constants/AustinFlinkConstant.java | 2 +- austin-web/src/main/resources/application.properties | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 48b34e5..a6b95f3 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 @@ -12,7 +12,7 @@ public class AustinFlinkConstant { * (真实网络ip,这里不能用配置的hosts，看语雀文档得到真实ip) */ public static final String GROUP_ID = "austinLogGroup"; - public static final String TOPIC_NAME = "austinLog"; + public static final String TOPIC_NAME = "austinTraceLog"; public static final String BROKER = "austin.kafka"; /** diff --git a/austin-web/src/main/resources/application.properties b/austin-web/src/main/resources/application.properties index 1e7dbc6..ecf9a99 100644 --- a/austin-web/src/main/resources/application.properties +++ b/austin-web/src/main/resources/application.properties @@ -58,7 +58,7 @@ spring.redis.password=${austin-redis-password} austin.business.topic.name=austinBusiness austin.business.recall.topic.name=austinRecall austin.business.recall.group.name=recallGroupId -austin.business.log.topic.name=austinLog +austin.business.log.topic.name=austinTraceLog austin.business.graylog.ip=${austin-grayLog-ip} # TODO kafka tag filter,if you need, replace tagIdValue ,eg:com.java3y.austin.yyy