扩展协议网关统计问题咨询

[Alunx]

通过扩展协议网关接受设备上报的数据后转投emqx broker，然后在通过规则引擎全部转发到kafka后，看 集群概览 发现消息都归到 消息丢弃 这一类里面了

我倒是看到你们加的说明了

但是这种情况下怎么处理比较好
我看你们之前的博客也是这么搞的车联网平台百万级消息吞吐架构设计 | EMQ

[zhongwencool]

规则把消息转到 Kafka 成功，messages.dropped.no_subscribers 也可能同时增长。
messages.dropped.no_subscribers 的语义是“Broker 在转发到 MQTT 订阅链路时发现没有订阅者”，它不代表规则动作失败。
你这个场景（设备 → 协议网关 → Broker → 规则 → Kafka）建议这样看：

1. 用规则页的运行统计判断链路是否成功：命中数、动作成功、动作失败。
2. messages.dropped.no_subscribers 只用来判断“这个 MQTT 主题当前有没有订阅端”。
3. 如果你就是不想让这个 dropped 指标增长，只能让该主题存在订阅者（例如挂一个内部消费端/黑洞订阅者）。
   目前没有其它的办法了。