V2EX › l970090853 的所有回复 › 第 1 页 / 共 1 页

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

129 天前

原因是 RocketMQ 的消费者是全额拉取 topic 的消息，然后在本地过滤的。（不是该消费者配置 tag 的消息会被过滤掉）
比如只有 t1 ，t2 两条消息，则消费者拉取到[t1, t2]两条消息，过滤了后只剩 t1 一条消息，然后吐给你的 listener 处理。