From 9473f4e8fdd1c677ee30bead6b8abfd25c0eb14e Mon Sep 17 00:00:00 2001 From: jiacheo Date: Fri, 2 Nov 2018 01:48:17 +0800 Subject: [PATCH] Update CanalMessageDeserializer.java fix lazyParseEntry 'raw' wrong value. --- .../alibaba/otter/canal/client/CanalMessageDeserializer.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java b/client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java index b2206890..9d24a23b 100644 --- a/client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java +++ b/client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java @@ -32,10 +32,12 @@ public class CanalMessageDeserializer { if (lazyParseEntry) { // byteString result.setRawEntries(messages.getMessagesList()); + result.setRaw(true); } else { for (ByteString byteString : messages.getMessagesList()) { result.addEntry(CanalEntry.Entry.parseFrom(byteString)); } + result.setRaw(false); } return result; }