|
@@ -32,10 +32,12 @@ public class CanalMessageDeserializer {
|
|
if (lazyParseEntry) {
|
|
if (lazyParseEntry) {
|
|
// byteString
|
|
// byteString
|
|
result.setRawEntries(messages.getMessagesList());
|
|
result.setRawEntries(messages.getMessagesList());
|
|
|
|
+ result.setRaw(true);
|
|
} else {
|
|
} else {
|
|
for (ByteString byteString : messages.getMessagesList()) {
|
|
for (ByteString byteString : messages.getMessagesList()) {
|
|
result.addEntry(CanalEntry.Entry.parseFrom(byteString));
|
|
result.addEntry(CanalEntry.Entry.parseFrom(byteString));
|
|
}
|
|
}
|
|
|
|
+ result.setRaw(false);
|
|
}
|
|
}
|
|
return result;
|
|
return result;
|
|
}
|
|
}
|