From f8706bfa1d8eb5d854b63c1f05dbdea72da542ed Mon Sep 17 00:00:00 2001 From: qidaijie Date: Tue, 28 Sep 2021 09:45:17 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E8=8B=A5=E4=BE=9D=E8=B5=96?= =?UTF-8?q?=E5=88=A4=E6=96=AD=E4=BD=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- properties/service_flow_config.properties | 10 ++++++---- .../com/zdjizhi/utils/general/TransFormTypeMap.java | 5 +++-- 2 files changed, 9 insertions(+), 6 deletions(-) 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 jsonMap = (Map) JsonMapper.fromJsonString(message, Map.class); + Map map = (Map) JsonMapper.fromJsonString(message, Map.class); + Map 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 ""; }