Hi,
I have the following parameters:
streamEntry, err := streamdb.XReadGroup(ctx, &redis.XReadGroupArgs{
Group: consumerGroup,
Consumer: consumer,
Streams: []string{w.wengineRedis.RedisReadStream, ">"},
Count: 1,
Block: 0,
NoAck: false,
}).Result()
If all consumers in this group are down, and a message comes into the RedisReadStream, it is not picked up by any of the consumers once they are restarted. I thought the ">" would handle this but it does not seem to be working...