5.3 Reader接口:非订阅式消费与精确位置读取 5.3 Reader接口:非订阅式消费与精确位置读取 在 Apache Pulsar 的客户端体系中,消息消费模型通常以 Consumer(消费者)为核心,其背后依托的是持久化的订阅机制。这种模式天然适用于绝大多数流处理场景——系统自动维护消费偏移、支持故障恢复、允许多租户共享主题。然而,在某些对数据访问方式有更高自由度要求的场景下,传统订阅模型显得过于“重”了。正是在这样的背景下,Pulsar 提供了 Reader 接口,一种轻量级、无状态、非订阅式的消费模型。它不绑定任何订阅名称,也不依赖游标管理,而是允许开发者以近乎“裸金属”的方式直接读取消息队列中的任意位置。 那么,Reader 究竟是如何工作的?