You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

go-redis v8的XAutoClaim命令与Redis v7+服务器不兼容问题求助

go-redis v8 对接 Redis v7+ 时 XAutoClaim 命令兼容性问题

问题说明

使用go-redis v8连接Redis v7+服务器实例时,调用client.XAutoClaim会返回错误:got 3, wanted 2。目前go-redis/v8官方的XAutoClaim文档中未提及该命令与Redis v7+存在不兼容情况。

复现代码

ctx := context.Background()

streamName := "test-stream"
groupName := "test-group"

rdb := redis.NewClient(&redis.Options{
    Addr:     "localhost:6379",
    Password: "", // 无密码设置
    DB:       0,  // 使用默认数据库
})
defer rdb.FlushDB(ctx).Err()

// 向流中添加消息
rdb.XAdd(ctx, &redis.XAddArgs{
    Stream: streamName,
    Values: map[string]interface{}{"key": "value"},
})

// 创建消费者组
rdb.XGroupCreateMkStream(ctx, streamName, groupName, "0")

autoclaimError := rdb.XAutoClaim(ctx, &redis.XAutoClaimArgs{
    Stream:       streamName,
    Group:        groupName,
    Consumer:     "test-consumer",
    MinIdle:      0,
    Start:        "-",
    Count:        1,
}).Err()
print(autoclaimError.Error())

内容的提问来源于stack exchange,提问作者Matt C.

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.04 17:04:55