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
 		}