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.
相关产品推荐
相关产品推荐

