always call consumer process even if reach end (#345)

crimson-gao · web-flow · commit e1303e2e06e4 · 2025-07-16T19:59:39.000+08:00
diff --git a/consumer/shard_worker.go b/consumer/shard_worker.go
@@ -115,7 +115,9 @@ func (c *ShardConsumerWorker) fetchLogs(cursor string) (shouldCallProcess bool,
 	if cursor == plm.NextCursor { // already reach end of shard
 		c.saveCheckPointIfNeeded()
 		time.Sleep(noProgressSleepTime)
-		return false, nil, nil
+		return true, &sls.LogGroupList{
+			LogGroups: make([]*sls.LogGroup, 0),
+		}, nil
 	}
 	return true, logGroupList, plm
 }

Original file line number	Diff line number	Diff line change
`@@ -115,7 +115,9 @@ func (c *ShardConsumerWorker) fetchLogs(cursor string) (shouldCallProcess bool,`
`115`	`115`	`if cursor == plm.NextCursor { // already reach end of shard`
`116`	`116`	`c.saveCheckPointIfNeeded()`
`117`	`117`	`time.Sleep(noProgressSleepTime)`
`118`		`- return false, nil, nil`
	`118`	`+ return true, &sls.LogGroupList{`
	`119`	`+ LogGroups: make([]*sls.LogGroup, 0),`
	`120`	`+ }, nil`
`119`	`121`	`}`
`120`	`122`	`return true, logGroupList, plm`
`121`	`123`	`}`