diff --git a/core/src/main/java/net/momirealms/customfishing/bukkit/storage/method/database/nosql/RedisManager.java b/core/src/main/java/net/momirealms/customfishing/bukkit/storage/method/database/nosql/RedisManager.java
index 03ed1c6a..a6d179f6 100644
--- a/core/src/main/java/net/momirealms/customfishing/bukkit/storage/method/database/nosql/RedisManager.java
+++ b/core/src/main/java/net/momirealms/customfishing/bukkit/storage/method/database/nosql/RedisManager.java
@@ -364,7 +364,7 @@ public class RedisManager extends AbstractStorage {
         public BlockingThreadTask() {
             Thread thread = new Thread(() -> {
                 var map = new HashMap<String, StreamEntryID>();
-                map.put(getStream(), StreamEntryID.LAST_ENTRY);
+                map.put(getStream(), StreamEntryID.XREAD_NEW_ENTRY);
                 while (!this.stopped) {
                     try {
                         var connection = getJedis();