Merge pull request #48 from open-source-go/del_dev

ack时判断成功状态以避免一个会引起崩溃的队列顺序问题
withlin · Feb 27, 2020 · 96bf8b8 · 96bf8b8
2 parents 33ac8c2 + 0bb1a3f
commit 96bf8b8
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/client/simple_canal_connector.go b/client/simple_canal_connector.go
@@ -253,7 +253,10 @@ func (c *SimpleCanalConnector) Get(batchSize int32, timeOut *int64, units *int32
 	if err != nil {
 		return nil, err
 	}
-	c.Ack(message.Id)
+	err = c.Ack(message.Id)
+	if err != nil {
+		return nil, err
+	}
 	return message, nil
 }