~queue;

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisStreamConfig.java

@@ -65,7 +65,7 @@ public class RedisStreamConfig {
                     System.out.println("errorHandler: " + t.getMessage());
                 })
                 // 超时时间，设置为0，表示不超时（超时后会抛出异常）
-                .pollTimeout(Duration.ZERO)
+                .pollTimeout(Duration.ofMillis(1))
                 .build();
         return StreamMessageListenerContainer.create(factory, options);
     }