l970090853 最近的时间轴更新 l970090853 最近的时间轴更新 |
l970090853V2EX 第 315144 号会员，加入于 2018-05-08 23:13:01 +08:00 |
l970090853 最近回复了
129 天前 回复了 yesterdaysun 创建的主题 › Java › RocketMQ 拉取消费过滤条件的问题 |
原因是 RocketMQ 的消费者是全额拉取 topic 的消息，然后在本地过滤的。（不是该消费者配置 tag 的消息会被过滤掉）
比如只有 t1 ，t2 两条消息，则消费者拉取到[t1, t2]两条消息，过滤了后只剩 t1 一条消息，然后吐给你的 listener 处理。
比如只有 t1 ，t2 两条消息，则消费者拉取到[t1, t2]两条消息，过滤了后只剩 t1 一条消息，然后吐给你的 listener 处理。
Select Language