MemoryEventStoreWithBuffer#get应尽可能返回完整的事务，并且不要截断事务

为什么需要？ int batchSize = 1024; ClientIdentity identity = xxx; CanalServerWithEmbedded server = new CanalServerWithEmbedded(); // here, it needs return all complete transactions, but the data maybe truncated in two invokes server.getWithoutAck(identity, batchSize);

怎么实现 现在在MemoryEventStoreWithBuffer#doGet:

long memsize = 0; if (batchMode.isItemSize()) { end = (next + batchSize - 1) < maxAbleSequence ? (next + batchSize - 1) : maxAbleSequence; for (; next <= end; next++) { Event event = entries[getIndex(next)]; if (ddlIsolation && isDdl(event.getEventType())) { if (entrys.size() == 0) { entrys.add(event); end = next; } else { end = next - 1; } break; } else { // changes here: should determine whether event in a transaction entrys.add(event); } } }

示例

batchSize < 5, return tx1. get index moved to 4 batchSize >=5 && batchSize < 10, just return tx1. get index moved to 4 batchSize >= 10 && batchSize < 13, just return tx1,tx2. get index moved to 10

原提问者GitHub用户xiaoma20082008