fix: consumer pull logs 3 times (#286)

* fix: consumer pull logs 3 times * retract mod version
aliyun · Jun 14, 2024 · 5c752df · 5c752df
1 parent 13f3d20
commit 5c752df
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/consumer/consumer_client.go b/consumer/consumer_client.go
@@ -171,6 +171,8 @@ func (consumer *ConsumerClient) pullLogs(shardId int, cursor string) (gl *sls.Lo
 					"tryTimes", retry+1)
 			}
 			time.Sleep(200 * time.Millisecond)
+		} else {
+			return gl, plm, nil
 		}
 	}
 	// If you can't retry the log three times, it will return to empty list and start pulling the log cursor,

diff --git a/go.mod b/go.mod
@@ -46,4 +46,4 @@ require (
 	gopkg.in/yaml.v2 v2.2.8 // indirect
 )
 
-retract v0.1.73
+retract [v0.1.70, v0.1.78]