diff options
| author | qidaijie <[email protected]> | 2022-09-20 10:42:23 +0800 |
|---|---|---|
| committer | qidaijie <[email protected]> | 2022-09-20 10:42:23 +0800 |
| commit | b7eddb0e8c8f174ec34b79454016d537c3a75ccc (patch) | |
| tree | f6a300409101a35d90e6c0aa69058ef53e377399 | |
| parent | 76fe5df4ad807f578d751421b83388eae4a00c68 (diff) | |
新增基于schema填充默认值功能（TSG-11886）
| -rw-r--r-- | src/main/java/com/zdjizhi/utils/json/JsonParseUtil.java | 2 | ||||
| -rw-r--r-- | src/main/java/com/zdjizhi/utils/kafka/TimestampDeserializationSchema.java | 1 |
2 files changed, 0 insertions, 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; |