We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9b88753 commit 516c31fCopy full SHA for 516c31f
sample/CanalSharp.SimpleClient/Program.cs
@@ -21,8 +21,9 @@ static void Main(string[] args)
21
connector.Subscribe(".*\\\\..*");
22
while (true)
23
{
24
- //获取消息数据
25
- var message = connector.Get(5000);
+ //获取数据 1024表示数据大小 单位为字节
+ var message = connector.Get(1024);
26
+ //批次id 可用于回滚
27
var batchId = message.Id;
28
if (batchId == -1 || message.Entries.Count <= 0)
29
0 commit comments