标签：Filtersrv

kafka

消息中间件 RocketMQ 源码解析：Filtersrv

本文主要基于 RocketMQ 4.0.x 正式版概述Filtersrv 注册到 Broker过滤类3.1 Consumer 订阅时设置 过滤类代码3.2 Consumer 上传 过滤类代码3.3 Filter 编译 过滤类代码过滤消息4.1 Consumer 从 Filtersrv 拉取消息4.2 Filtersrv 从 Broker ……