From fd9074de9b95d8bdc6028082a39fd5f1be9722ce Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Thu, 25 Jun 2026 13:59:45 +0800 Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4~=E8=BF=91=E4=BC=BC=E8=A3=81?= =?UTF-8?q?=E5=89=AA=E9=80=89=E9=A1=B9=EF=BC=8C=E6=9B=BF=E6=8D=A2=E6=88=90?= =?UTF-8?q?=E9=AB=98=E7=BA=A7API=E8=B0=83=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../middle/stream/support/StreamTrimScheduler.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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) 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) 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); }