diff --git a/common/src/main/java/com/alibaba/otter/canal/common/utils/JsonUtils.java b/common/src/main/java/com/alibaba/otter/canal/common/utils/JsonUtils.java index b9a5848c..5eba81e8 100644 --- a/common/src/main/java/com/alibaba/otter/canal/common/utils/JsonUtils.java +++ b/common/src/main/java/com/alibaba/otter/canal/common/utils/JsonUtils.java @@ -94,5 +94,17 @@ public class JsonUtils { // 优先使用name serializer.write(address.getHostName()); } + + public void write(JSONSerializer serializer, Object object, Object fieldName, Type fieldType, int features) + throws IOException { + if (object == null) { + serializer.writeNull(); + return; + } + + InetAddress address = (InetAddress) object; + // 优先使用name + serializer.write(address.getHostName()); + } } }