MQTT Bridge接收消息时,[error] [PoolWorker] unexpected info

使用 v5.1.5-build.3-g81055fbb 版本开源emqx,
建立了一个mqtt bridge,且链接正常。
出口消息可以正常转到的远端,但远端发送消息时,会报错:

2023-08-24T10:25:53.011645+00:00 [debug] msg: RECV_Data, mfa: emqtt:handle_event/4, line: 1361, clietntid: <<“jkbMHitQ|securemode=2,signmethod=sha256,timestamp=1692858598550|:bridge:mqtt:starbucksgw001:egress:emqx@127.0.0.1:1”>>, data: <<48,169,1,0,64,47,115,121,115,47,106,107,98,77,72,105,116,81,47,115,116,97,114,98,117,99,107,115,103,119,48,48,49,47,116,104,105,110,103,47,115,101,114,118,105,99,101,47,102,108,101,101,116,95,99,111,110,116,114,111,108,95,115,101,114,118,105,99,101,123,34,105,100,34,58,34,51,51,56,57,51,49,52,53,52,48,50,48,55,51,49,54,57,57,50,34,44,34,109,…>>
2023-08-24T10:25:53.019771+00:00 [error] [PoolWorker] unexpected info: {publish,#{client_pid => <0.2907.0>,dup => false,packet_id => undefined,payload => <<“{"id":"3389314540207316992","method":"thing.service.fleet_control_service","params":{},"version":"1.0"}”>>,properties => undefined,qos => 0,retain => false,topic => <<“/sys/jkbMHitQ/starbucksgw001/thing/service/fleet_control_service”>>,via => #Port<0.17>}}

也没有找到RECV_Data, mfa: emqtt:handle_event/4, line: 136 相关代码位置以进行调试。

找到原因了。远程只允许一个客户端连接。所以入口ingress client就链接中断了,所以有办法将 入口和 出口 合并成一个client完成么?

现在是没有办法的。你的业务场景里面,MQTT Bridge 必须用单个 clientid 同时接收和发送消息吗?