canal 1.1.0 的Entry解析性能问题

这里entry.toByteString()是基于什么考虑？我们从canal 1.0.24升级到1.1.0，发现性能差了很多。 我看到这个地方，已经拿到Entry对象了，应该可以缓存起来，这样业务上就不需要再次做一次parse了。

public Event(LogIdentity logIdentity, CanalEntry.Entry entry){
    this.logIdentity = logIdentity;
    this.entryType = entry.getEntryType();
    this.executeTime = entry.getHeader().getExecuteTime();
    this.journalName = entry.getHeader().getLogfileName();
    this.position = entry.getHeader().getLogfileOffset();
    this.serverId = entry.getHeader().getServerId();
    this.gtid = entry.getHeader().getGtid();
    this.eventType = entry.getHeader().getEventType();
    // build raw
    this.rawEntry = entry.toByteString();
    this.rawLength = rawEntry.size();
    if (entryType == EntryType.ROWDATA) {
        List<CanalEntry.Pair> props = entry.getHeader().getPropsList();
        if (props != null) {
            for (CanalEntry.Pair p : props) {
                if ("rowsCount".equals(p.getKey())) {
                    rowsCount = Integer.parseInt(p.getValue());
                    break;
                }
            }
        }
    }
}

类似的还有这里，其实已经有RowChange了，但是都被序列化成bytes了。

        RowChange rowChange = rowChangeBuider.build();
        if (tableError) {
            Entry entry = createEntry(header, EntryType.ROWDATA, ByteString.EMPTY);
            logger.warn("table parser error : {}storeValue: {}", entry.toString(), rowChange.toString());
            return null;
        } else {
            Entry entry = createEntry(header, EntryType.ROWDATA, rowChange.toByteString());
            return entry;
        }

我们用的是 CanalServerWithEmbedded

原提问者GitHub用户toruneko