Redis消费者组能否保证多消费者并行消费同一Stream时各取互斥子集？

消费者组能否保证同组多消费者拿到互斥消息、单条消息仅被处理一次？ #

可以，Redis消费者组的原生机制默认保证同组内的多个消费者拿到的是互斥的未消费消息子集。消费者组会维护组级别全局的最后递送ID，当使用>作为读取ID参数时，Redis只会返回从未递送给组内任何消费者的新消息，且同一条消息只会递送给组内的一个消费者，分发侧不会出现重复分发的情况。

仅使用xreadgroup group mygroup consumer1 [count 1000] streams mystream >命令是否足够？ #

完全不够，你还需要补充以下逻辑才能实现真正的消息仅处理一次、不丢消息：

• 消费完成后必须执行确认操作：消费者处理完每条消息后，必须调用XACK命令通知Redis，该消息才会从消费者组的待处理条目列表（PEL）中移除。如果不执行XACK，消息会一直保留在当前消费者的待处理列表中，一旦消费者宕机未完成处理，消息会处于无人处理的状态。
• 必须补充异常重试机制：你需要定期通过XPENDING命令扫描消费者组内所有待处理的消息，对超过合理处理时长仍未被确认的消息，调用XCLAIM命令将其转移给正常存活的消费者重新处理，避免消费者宕机导致消息遗漏。
• 业务侧需要补充幂等校验：如果你的消费逻辑是先处理业务再执行XACK，那么极端情况下（业务处理完成、XACK请求未发送到Redis时进程崩溃）会出现同一条消息被重新分发的情况，此时需要业务侧对消息做幂等校验，避免重复执行业务逻辑。

内容的提问来源于stack exchange，提问作者Spaceship222