diff --git a/ClientExample.md b/ClientExample.md index 40b2cde..6c06e29 100644 --- a/ClientExample.md +++ b/ClientExample.md @@ -63,8 +63,8 @@ public class SimpleCanalClientExample { connector.connect(); connector.subscribe(".*\\..*"); connector.rollback(); - int totalEmtryCount = 120; - while (emptyCount < totalEmtryCount) { + int totalEmptyCount = 120; + while (emptyCount < totalEmptyCount) { Message message = connector.getWithoutAck(batchSize); // 获取指定数量的数据 long batchId = message.getId(); int size = message.getEntries().size();