vip:修复非kafka tag过滤的逻辑

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 配置

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