From 47d9e75d392efacd2adf82302cec1917c7852c2b Mon Sep 17 00:00:00 2001 From: 3y Date: Thu, 7 Jul 2022 20:30:37 +0800 Subject: [PATCH] =?UTF-8?q?vip:=E4=BF=AE=E5=A4=8D=E9=9D=9Ekafka=20tag?= =?UTF-8?q?=E8=BF=87=E6=BB=A4=E7=9A=84=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java3y/austin/stream/constants/AustinFlinkConstant.java | 2 +- .../main/java/com/java3y/austin/support/utils/KafkaUtils.java | 4 ++-- 2 files changed, 3 insertions(+), 3 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 5498a67..48b34e5 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 @@ -13,7 +13,7 @@ public class AustinFlinkConstant { */ public static final String GROUP_ID = "austinLogGroup"; public static final String TOPIC_NAME = "austinLog"; - public static final String BROKER = "austin.flink"; + public static final String BROKER = "austin.kafka"; /** * redis 配置 diff --git a/austin-support/src/main/java/com/java3y/austin/support/utils/KafkaUtils.java b/austin-support/src/main/java/com/java3y/austin/support/utils/KafkaUtils.java index b2a1587..4550491 100644 --- a/austin-support/src/main/java/com/java3y/austin/support/utils/KafkaUtils.java +++ b/austin-support/src/main/java/com/java3y/austin/support/utils/KafkaUtils.java @@ -29,13 +29,13 @@ public class KafkaUtils { private String tagIdKey; /** - * 发送kafka消息 + * 发送kafka消息(不支持tag过滤） * * @param topicName * @param jsonMessage */ public void send(String topicName, String jsonMessage) { - kafkaTemplate.send(topicName, jsonMessage, null); + send(topicName, jsonMessage, null); } /**