fix: add query (#285)

aliyun · Jun 13, 2024 · 13f3d20 · 13f3d20
1 parent 9237ddf
commit 13f3d20
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/consumer/consumer_client.go b/consumer/consumer_client.go
@@ -145,6 +145,7 @@ func (consumer *ConsumerClient) pullLogs(shardId int, cursor string) (gl *sls.Lo
 		Logstore:         consumer.option.Logstore,
 		ShardID:          shardId,
 		Cursor:           cursor,
+		Query:            consumer.option.Query,
 		LogGroupMaxCount: consumer.option.MaxFetchLogGroupCount,
 		CompressType:     consumer.option.CompressType,
 	}