From 0d78f8eedb4f25ff2ef5092d7cd87873d1e0d53b Mon Sep 17 00:00:00 2001
From: "suxiaobin.sxb" <suxiaobin.sxb@alibaba-inc.com>
Date: Wed, 3 Jan 2024 23:13:16 +0800
Subject: [PATCH] bugfix: fix stream parsing issue

---
 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 a86cfa68..33ced193 100644
--- a/internal/rdb/types/stream.go
+++ b/internal/rdb/types/stream.go
@@ -141,7 +141,7 @@ func (o *StreamObject) readStream(rd io.Reader, masterKey string, typeByte byte)
 	 * in case of XDEL lastid. */
 	o.cmds = append(o.cmds, []string{"xsetid", masterKey, lastid})
 
-	if typeByte == rdbTypeStreamListpacks2 {
+	if typeByte >= rdbTypeStreamListpacks2 {
 		/* Load the first entry ID. */
 		_ = structure.ReadLength(rd) // first_ms
 		_ = structure.ReadLength(rd) // first_seq