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);
     }
 
     /**