Fixed - RStream.trim() and trimNonStrict() methods don't work with Redis 6.2+ #5353

redisson/src/main/java/org/redisson/RedissonStream.java

@@ -1406,7 +1406,7 @@ public class RedissonStream<K, V> extends RedissonExpirable implements RStream<K
         List<Object> params = new LinkedList<>();
         params.add(getRawName());
 
-        if (pps.getMaxLen() > 0) {
+        if (pps.getMaxLen() != null) {
             params.add("MAXLEN");
             if (!trimStrict) {
                 params.add("~");

redisson/src/main/java/org/redisson/api/stream/StreamTrimParams.java

@@ -26,7 +26,7 @@ public final class StreamTrimParams implements StreamTrimStrategyArgs<StreamTrim
                                          StreamTrimArgs,
                                          StreamTrimLimitArgs<StreamTrimArgs> {
 
-    int maxLen;
+    Integer maxLen;
     StreamMessageId minId;
     int limit;
 
@@ -62,7 +62,7 @@ public final class StreamTrimParams implements StreamTrimStrategyArgs<StreamTrim
         return this;
     }
 
-    public int getMaxLen() {
+    public Integer getMaxLen() {
         return maxLen;
     }
 

redisson/src/test/java/org/redisson/RedissonStreamTest.java

@@ -106,6 +106,10 @@ public class RedissonStreamTest extends BaseTest {
         stream.add(StreamAddArgs.entry("2", "2"));
 
         assertThat(stream.trim(StreamTrimArgs.maxLen(2).noLimit())).isEqualTo(1);
+
+        RStream<String, String> stream2 = redisson.getStream("myStream");
+        StreamTrimArgs trimArgs = StreamTrimArgs.maxLen(0).noLimit();
+        assertThat(stream2.trim(trimArgs)).isZero();
     }
 
     @Test