From ad4d0a506a469743b5d619f3290310325e965a11 Mon Sep 17 00:00:00 2001 From: monkey92t Date: Thu, 27 May 2021 11:24:24 +0800 Subject: [PATCH] fix #1766 --- commands.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/commands.go b/commands.go index 9c64390..3dc06bb 100644 --- a/commands.go +++ b/commands.go @@ -1773,7 +1773,7 @@ func (c cmdable) XReadGroup(ctx context.Context, a *XReadGroupArgs) *XStreamSlic args := make([]interface{}, 0, 8+len(a.Streams)) args = append(args, "xreadgroup", "group", a.Group, a.Consumer) - keyPos := int8(1) + keyPos := int8(4) if a.Count > 0 { args = append(args, "count", a.Count) keyPos += 2