fix: fix missing group offset for stream type RDB_TYPE_STREAM_LISTPAC…

…KS_3
tair-opensource · Nov 22, 2024 · d189d9d · d189d9d
1 parent e3bf5c2
commit d189d9d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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
 		}