diff --git a/rag/utils/redis_conn.py b/rag/utils/redis_conn.py
index ef1b73eaa..2ab670637 100644
--- a/rag/utils/redis_conn.py
+++ b/rag/utils/redis_conn.py
@@ -117,7 +117,7 @@ class RedisDB:
                 self.REDIS.xgroup_create(
                     queue_name,
                     group_name,
-                    id="$",
+                    id="0",
                     mkstream=True
                 )
             args = {