diff --git a/src/main/java/com/njcn/middle/stream/support/StreamTrimScheduler.java b/src/main/java/com/njcn/middle/stream/support/StreamTrimScheduler.java
index dc3b41d..f5eb03c 100644
--- a/src/main/java/com/njcn/middle/stream/support/StreamTrimScheduler.java
+++ b/src/main/java/com/njcn/middle/stream/support/StreamTrimScheduler.java
@@ -81,11 +81,11 @@ public class StreamTrimScheduler implements SmartLifecycle {
         long maxlen = props.getTrim().getMaxlen();
         for (String stream : distinctStreams()) {
             try {
-                redis.execute((RedisCallback<Object>) connection -> connection.execute("XTRIM",
-                        stream.getBytes(StandardCharsets.UTF_8),
-                        "MAXLEN".getBytes(StandardCharsets.UTF_8),
-                        "~".getBytes(StandardCharsets.UTF_8),
-                        String.valueOf(maxlen).getBytes(StandardCharsets.UTF_8)));
+                redis.opsForStream().trim(stream,maxlen);
+//                redis.execute((RedisCallback<Object>) connection -> connection.execute("XTRIM",
+//                        stream.getBytes(StandardCharsets.UTF_8),
+//                        "MAXLEN".getBytes(StandardCharsets.UTF_8),
+//                        String.valueOf(maxlen).getBytes(StandardCharsets.UTF_8)));
             } catch (Exception e) {
                 log.warn("[redis-stream] trim failed stream={}", stream, e);
             }