diff --git a/properties/service_flow_config.properties b/properties/service_flow_config.properties
index 362a264..a0c7fc2 100644
--- a/properties/service_flow_config.properties
+++ b/properties/service_flow_config.properties
@@ -1,10 +1,10 @@
 #--------------------------------地址配置------------------------------#
 
 #管理kafka地址
-input.kafka.servers=192.168.44.12:9091
+input.kafka.servers=192.168.44.12:9094
 
 #管理输出kafka地址
-output.kafka.servers=192.168.44.12:9091
+output.kafka.servers=192.168.44.12:9094
 
 #zookeeper 地址 用于配置log_id
 zookeeper.servers=192.168.44.12:2181
@@ -25,10 +25,12 @@ app.id.http=http://192.168.44.12:9999/open-api/appDicList
 #--------------------------------Kafka消费组信息------------------------------#
 
 #kafka 接收数据topic
-input.kafka.topic=SESSION-RECORD
+#input.kafka.topic=SESSION-RECORD
+input.kafka.topic=test
 
 #补全数据 输出 topic
-output.kafka.topic=SESSION-RECORD-COMPLETED
+#output.kafka.topic=SESSION-RECORD-COMPLETED
+output.kafka.topic=test-result
 
 #读取topic,存储该spout id的消费offset信息，可通过该拓扑命名;具体存储offset的位置，确定下次读取不重复的数据；
 group.id=session-record-log-20210902-1
diff --git a/src/main/java/com/zdjizhi/utils/general/TransFormTypeMap.java b/src/main/java/com/zdjizhi/utils/general/TransFormTypeMap.java
index 7779da2..4423f51 100644
--- a/src/main/java/com/zdjizhi/utils/general/TransFormTypeMap.java
+++ b/src/main/java/com/zdjizhi/utils/general/TransFormTypeMap.java
@@ -38,7 +38,8 @@ public class TransFormTypeMap {
     public static String dealCommonMessage(String message) {
         try {
             if (StringUtil.isNotBlank(message)) {
-                Map<String, Object> jsonMap = (Map<String, Object>) JsonMapper.fromJsonString(message, Map.class);
+                Map<String, Object> map = (Map<String, Object>) JsonMapper.fromJsonString(message, Map.class);
+                Map<String, Object> jsonMap = JsonTypeUtils.typeTransform(map);
                 for (String[] strings : jobList) {
                     //用到的参数的值
                     Object logValue = JsonParseUtil.getValue(jsonMap, strings[0]);
@@ -52,7 +53,7 @@ public class TransFormTypeMap {
                     String param = strings[3];
                     functionSet(function, jsonMap, appendToKeyName, appendToKeyValue, logValue, param);
                 }
-                return JsonMapper.toJsonString(JsonTypeUtils.typeTransform(jsonMap));
+                return JsonMapper.toJsonString(jsonMap);
             } else {
                 return "";
             }