XReadGroup not picking up new messages after consumers were down

15 views
Skip to first unread message

Jayson Hurd

unread,
Jul 11, 2022, 11:12:42 AM7/11/22
to Redis DB
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...  
Reply all
Reply to author
Forward
0 new messages