EMQX桥接功能咨询

EMQX 其他
1

我们使用EMQX开源版本 5.1.0 桥接数据到企业版本EMQX中，发现桥接的速率是规则匹配速率的2倍

image
image1898×596 41.8 KB

image
image1920×623 47.2 KB

这个问题导致我们桥接到别处的企业版本EMQX的数据重复了

以下是我桥接的配置信息

image
image1920×639 37.2 KB

image
image1920×919 63.7 KB

image
image1920×919 62.7 KB

2

只有这一条规则么？

3

是的

4

群里的朋友说，可能是集群之前桥接导致。是不是要使用共享订阅来避免。我再源集群配置如下

image
image1920×919 62.9 KB

5

删掉右边 action 配置中的 “本地MQTT服务主题”

image
image1673×939 77.5 KB

mqtt 连接器从规则中获取到了一条消息
从 “本地MQTT服务主题” 中订阅到了同样的消息
就会导致发送两条消息。

“本地MQTT服务主题” 是为了便利，在无规则时使用 MQTT 桥接时使用的。

6

好的我试试。非常感谢官方大佬支持

7

出现了另外一个问题，目的集群的桥接都Kafka，不显示速率

image
image1896×674 43.3 KB

规则速率是有的
image
image1920×621 51.9 KB

Kafka里面也有数据过来。只是页面上不展示速率

8

规则配置如下

image
image1919×804 49.2 KB

9

企业版的本是？
日志有报错信息么？日志打包一下贴上来看看

10

所用企业EMQX： :5.3.1

日志提示：
2024/4/11 14:51:062024-04-11T06:51:06.667325+00:00 [warning] msg: out_of_service, mfa: emqx_rule_runtime:handle_action/4(333), peername: 101.217.131.11:39360, clientid: bridge:mqtt:NOLP_SCHEDULE_STATUS_BRIDGE:egress:emqx@10.42.77.140:2, action: {bridge_v2,kafka_producer,‘EE_SCHEDULE_BRIDGE’}
2024/4/11 14:51:062024-04-11T06:51:06.667292+00:00 [warning] msg: out_of_service, mfa: emqx_rule_runtime:handle_action/4(333), peername: 101.217.131.11:46616, clientid: bridge:mqtt:NOLP_SCHEDULE_STATUS_BRIDGE:egress:emqx@10.42.209.62:2, action: {bridge_v2,kafka_producer,‘EE_SCHEDULE_BRIDGE’}

{recoverable_error,<<“channel: "action:kafka_producer:EE_SCHEDULE_BRIDGE:connector:kafka_producer:connector_EE_SCHEDULE_BRIDGE" not operational”>>}
2024/4/11 14:38:352024-04-11T06:38:35.715909+00:00 [error] msg: send_error, mfa: emqx_resource_buffer_worker:handle_query_result_pure/3(941), peername: 10.42.160.14:49822, clientid: bridge:mqtt:NOPKI_SCHEDULE_STATUS_BRIDGE:egress:emqx@10.42.209.62:8, id: <<“action:kafka_producer:EE_SCHEDULE_BRIDGE:connector:kafka_producer:connector_EE_SCHEDULE_BRIDGE”>>, reason: {recoverable_error,<<“channel: "action:kafka_producer:EE_SCHEDULE_BRIDGE:connector:kafka_producer:connector_EE_SCHEDULE_BRIDGE" not operational”>>}
2024/4/11 14:38:352024-04-11T06:38:35.716230+00:00 [error] msg: send_error, mfa: emqx_resource_buffer_worker:handle_query_result_pure/3(941), peername: 10.42.160.14:49816, clientid: bridge:mqtt:NOPKI_SCHEDULE_STATUS_BRIDGE:egress:emqx@10.42.209.62:5, id: <<“action:kafka_producer:EE_SCHEDULE_BRIDGE:connector:kafka_producer:connector_EE_SCHEDULE_BRIDGE”>>, reason: {recoverable_error,<<“channel: "action:kafka_producer:EE_SCHEDULE_BRIDGE:connector:kafka_producer:connector_EE_SCHEDULE_BRIDGE" not operational”>>}
2024/4/11 14:38:352024-04-11T06:38:35.716556+00:00 [error] msg: send_error, mfa: emqx_resource_buffer_worker:handle_query_result_pure/3(941), peername: 10.42.160.14:49834, clientid: bridge:mqtt:NOPKI_SCHEDULE_STATUS_BRIDGE:egress:emqx@10.42.77.140:2, id: <<“action:kafka_producer:EE_SCHEDULE_BRIDGE:connector:kafka_producer:connector_EE_SCHEDULE_BRIDGE”>>, reason: {recoverable_error,<<“channel: "action:kafka_producer:EE_SCHEDULE_BRIDGE:connector:kafka_producer:connector_EE_SCHEDULE_BRIDGE" not operational”>>}

这些日志现在没有了，速率不展示。业务无影响

image
image1920×607 41.2 KB