Redis Stream中XACK确认后消息未删除，如何处理内存增长问题？

首先明确：XACK 仅用于将消息从消费者组的**待处理列表（PEL）**中移除，标记为已处理，但不会删除 Stream 中的原始消息，因此 Stream 长度会持续增长。以下是几种合理的解决方式：

1. 生产者写入时设置自动过期（MAXLEN） #

在调用 XADD 时指定 Stream 的最大长度，Redis 会自动删除超出长度的旧消息。推荐使用近似模式（~），避免精确删除带来的性能损耗：

修改生产者代码中的 XADD 调用：

// 保留最近1000条消息，~表示近似删除，性能更优
_, err := conn.Do("XADD", p.streamName, "MAXLEN", "~", 1000, "*", key, e)

也可以事后通过 XTRIM 命令为已存在的 Stream 设置规则：

XTRIM your-stream-name MAXLEN ~ 1000

2. 定期手动清理旧消息 #

通过定时任务定期执行清理命令，删除指定时间或 ID 之前的消息：

方式一：按最大长度清理 #

和 MAXLEN 逻辑一致，定期截断到指定长度：

XTRIM your-stream-name MAXLEN ~ 2000

方式二：按最小ID清理 #

删除所有 ID 小于指定值的消息，比如删除所有早于 1710000000000-0 的消息：

XTRIM your-stream-name MINID 1710000000000-0

方式三：删除指定ID的消息 #

如果能跟踪已处理的消息ID，可直接用 XDEL 删除单条或多条消息：

XDEL your-stream-name 1710000000000-0 1710000000001-0

在Go中可以用 time.Ticker 实现定时清理任务：

ticker := time.NewTicker(1 * time.Hour)
defer ticker.Stop()
for range ticker.C {
    _, err := conn.Do("XTRIM", "your-stream-name", "MAXLEN", "~", 1000)
    if err != nil {
        fmt.Printf("清理失败: %v\n", err)
    }
}

3. 结合消费者组状态清理已确认消息 #

利用消费者组的已处理状态，只清理所有消费者都已确认的旧消息：

1. 通过 XGROUP INFO your-group-name your-stream-name 获取组的 last-delivered-id（最后投递的消息ID）
2. 用 XTRIM 删除该ID之前的所有消息，确保这些消息已被所有消费者处理完成

示例Redis命令：

# 获取消费者组的last-delivered-id
XGROUP INFO my-group my-stream
# 假设返回的last-delivered-id是1710000000000-0，执行清理
XTRIM my-stream MINID 1710000000000-0

内容的提问来源于stack exchange，提问作者Ashutosh Pandey