用途：按 producer 契约通过 NATS MCP 工具批量拉取并消费 NATS 待处理消息，默认 drain-style，一次调用拉至队列空或达上限。
主要能力：读取项目缓存 .cortex/nats.yaml；定位 producer 契约并做版本兼容检查；契约缺失时进入 Bootstrap，peek 样本、推断 schema、生成 status: draft 草稿（仅 consumer 自用，不 ack、不改 offset）；建立或复用 JetStream pull consumer（durable 不存在则报错指向 IaC）；Drain 循环逐条处理；Tolerant Reader 解码（忽略未知字段，缺失必填走 term+DLQ，可重试错误走 nak）；业务不可恢复错误 term 并投 DLQ，附加失败原因 header；单条失败写入失败清单不中断整批；输出聚合回执（计数、失败详情、退出原因 drained/cap_reached/idle_timeout、续跑建议）。
必要用法：当前工作目录为 consumer repo，已连接 NATS MCP server，提供 mcp__nats__jetstream_pull_consumer、mcp__nats__ack、mcp__nats__nak、mcp__nats__term、mcp__nats__publish 等工具。
限制：不修改 producer 契约，草稿需用户审阅确认后手动升为 active；不创建 broker 资源（stream/durable 由 IaC 负责）；不负责实际业务处理逻辑；不支持长连续 push 订阅；未提供定价等信息。