更改 vip 写入 kafka 全链路追踪的topic

Tpjmay · Jul 7, 2022 · bd481fa · bd481fa
1 parent 47d9e75
commit bd481fa
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -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
@@ -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