From d189d9d5e9f651f14d1621c533f51bbf0fdc9ead Mon Sep 17 00:00:00 2001 From: "suxiaobin.sxb" Date: Fri, 22 Nov 2024 13:55:16 +0800 Subject: [PATCH] fix: fix missing group offset for stream type RDB_TYPE_STREAM_LISTPACKS_3 --- internal/rdb/types/stream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/rdb/types/stream.go b/internal/rdb/types/stream.go index 59b4de35..87b07260 100644 --- a/internal/rdb/types/stream.go +++ b/internal/rdb/types/stream.go @@ -188,7 +188,7 @@ func (o *StreamObject) readStream() { cmdC <- []string{"XGROUP", "CREATE", masterKey, groupName, lastid} /* Load group offset. */ - if typeByte == rdbTypeStreamListpacks2 { + if typeByte >= rdbTypeStreamListpacks2 { _ = structure.ReadLength(rd) // offset }