XREADGROUP
消费者组读取消息
语法
XREADGROUP GROUP group consumer [COUNT count] [BLOCK ms] STREAMS key [key ...] id [id ...]说明
XREADGROUP 通过消费者组读取 Stream 中的消息。消息被读取后进入 PEL（待确认列表），需用 XACK 确认。
参数
group必填消费者组名称
consumer必填消费者名称
COUNT最多返回消息数
BLOCK阻塞等待毫秒数
id必填> 表示从未消费的消息，其他 ID 表示已投递的消息
示例
消费新消息
消费者读取未处理的新消息
XREADGROUP GROUP mygroup consumer1 COUNT 10 BLOCK 5000 STREAMS mystream >重试未确认消息
读取已投递但未确认的消息
XREADGROUP GROUP mygroup consumer1 BLOCK 0 STREAMS mystream 0