redis runtime_error ai_generated partial

ERR 为流 'mystream' 上的消费者 'consumer1' 认领消息时超时

ERR Error claiming messages for consumer 'consumer1' on stream 'mystream': timeout

ID: redis/stream-group-claim-timeout

其他格式: JSON · Markdown 中文 · English
78%修复率
85%置信度
1证据数
2024-03-15首次发现

版本兼容性

版本状态引入弃用备注
Redis 7.2.0 active — — —
Redis 7.4.0 active — — —
Redis Stack 7.2.0 active — — —

根因分析

XCLAIM 命令超时，因为待处理条目列表 (PEL) 过大或消费者组负载过高，导致认领操作无法在空闲超时时间内完成。

English

The XCLAIM command timed out because the pending entries list (PEL) is too large or the consumer group is under heavy load, preventing the claim operation from completing within the idle timeout.

generic

官方文档

https://redis.io/commands/xclaim/

解决方案

  1. 使用 XINFO GROUPS 和 XINFO CONSUMERS 检查 PEL 大小，然后通过 XTRIM 或 XDEL 修剪待处理条目。例如：XINFO GROUPS mystream，然后对过期条目执行 XDEL mystream <id1> <id2>。
  2. 通过 XCLAIM 的 'idle' 参数增加消费者组的空闲超时，同时实现后台任务定期使用 XAUTOCLAIM 清理 PEL，设置合理的 count 参数。
  3. 扩展消费者数量以减少每个消费者的 PEL 大小，或使用流分区将负载分散到多个流上。

无效尝试

常见但无效的做法:

  1. 60% 失败

    Increasing the idle timeout for XCLAIM may hide the symptom but doesn't address the root cause of PEL bloat or consumer lag.

  2. 80% 失败

    Manually deleting large PEL entries without understanding the consumer group state can cause message loss or duplicate processing.

  3. 70% 失败

    Restarting the consumer group or Redis instance may temporarily clear the timeout but the PEL will rebuild from pending messages, leading to recurrence.