From b7eddb0e8c8f174ec34b79454016d537c3a75ccc Mon Sep 17 00:00:00 2001 From: qidaijie Date: Tue, 20 Sep 2022 10:42:23 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=9F=BA=E4=BA=8Eschema?= =?UTF-8?q?=E5=A1=AB=E5=85=85=E9=BB=98=E8=AE=A4=E5=80=BC=E5=8A=9F=E8=83=BD?= =?UTF-8?q?=EF=BC=88TSG-11886=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/zdjizhi/utils/json/JsonParseUtil.java | 2 -- .../com/zdjizhi/utils/kafka/TimestampDeserializationSchema.java | 1 - 2 files changed, 3 deletions(-) diff --git a/src/main/java/com/zdjizhi/utils/json/JsonParseUtil.java b/src/main/java/com/zdjizhi/utils/json/JsonParseUtil.java index 106fdb9..ac543ec 100644 --- a/src/main/java/com/zdjizhi/utils/json/JsonParseUtil.java +++ b/src/main/java/com/zdjizhi/utils/json/JsonParseUtil.java @@ -244,8 +244,6 @@ public class JsonParseUtil { String name = fieldJson.getStr("name"); String type = fieldJson.getStr("type"); if (fieldJson.containsKey("default")) { - System.out.println(fieldJson.toString()); - System.out.println(fieldJson.get("default")); defaultFieldsMap.put(name, fieldJson.get("default")); } //组合用来生成实体类的map diff --git a/src/main/java/com/zdjizhi/utils/kafka/TimestampDeserializationSchema.java b/src/main/java/com/zdjizhi/utils/kafka/TimestampDeserializationSchema.java index e38f9e6..920ffab 100644 --- a/src/main/java/com/zdjizhi/utils/kafka/TimestampDeserializationSchema.java +++ b/src/main/java/com/zdjizhi/utils/kafka/TimestampDeserializationSchema.java @@ -41,7 +41,6 @@ public class TimestampDeserializationSchema implements KafkaDeserializationSchem return json; } catch (RuntimeException e) { logger.error("KafkaConsumer Deserialize failed,The exception is : " + e.getMessage()); - e.printStackTrace(); } } return null;