chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

& lt; 修改为 <

puff
2018-02-26 09:27:36 +08:00
parent bdfefcfd87
commit b72a62124d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ClientExample.md

@@ -64,7 +64,7 @@ public class SimpleCanalClientExample {
connector.subscribe(".*\\..*"); connector.subscribe(".*\\..*");
connector.rollback(); connector.rollback();
int totalEmptyCount = 120; int totalEmptyCount = 120;
while (emptyCount &lt; totalEmptyCount) { while (emptyCount < totalEmptyCount) {
Message message = connector.getWithoutAck(batchSize); // 获取指定数量的数据 Message message = connector.getWithoutAck(batchSize); // 获取指定数量的数据
long batchId = message.getId(); long batchId = message.getId();
int size = message.getEntries().size(); int size = message.getEntries().size();