emqx桥接数据到另外一个emqx时数据一直丢弃,不能桥接到目的端emqx中

2023-11-05T00:17:54.646077+08:00 [error] crasher: initial call: emqtt:init/1, pid: <0.4171.4>, registered_name: , exit: {closed,[{gen_statem,loop_st
ate_callback_result,11,[{file,“gen_statem.erl”},{line,1397}]},{proc_lib,init_p_do_apply,3,[{file,“proc_lib.erl”},{line,226}]}]}, ancestors: [emqx_conn
ector_mqtt,emqx_connector_sup,<0.2625.0>], message_queue_len: 103, messages: [{publish,default,{mqtt_msg,0,false,false,undefined,<<“tiemao/91130230780
8371268/Online/13020901/Transfer/g_wavedata”>>,#{},<<“{"siteCode":"911302307808371268","measurePointId":"13020901-0-4-0-11","dataPackageType
“:"g_wavedata","dataSource":"doton","values":[{"ts":1699113788000,"extras":[{"dataType":1,"name":"wave data","fs":1000,"sp":0,"
fr":0,"data":[1.7619028,1.2192624,0.8294028,0.952642,1.56287,1.4975204,0.8106036,1.1222824,1.5227352,1.477826,1.0215724,0.405824,-0.097”…>>},infi
nity,{#Fun<emqx_connector_mqtt.0.124205462>,[{fun emqx_resource_buffer_worker:handle_async_reply/2,[#{buffer_worker => <0.2636.0>,inflight_tid => #Ref
<0.3258589376.2552102913.18607>,min_query => {query,undefined,,false,-576243565348885560},query_opts => #{inflight_tid => #Ref<0.3258589376.25521029
13.18607>,simple_query => false},request_ref => -576243580348482362,resource_id => <<“bridge:mqtt:tiemao-cloud”>>,worker_index => 2}]}]}},{publish,def
ault,{mqtt_msg,0,false,false,undefined,<<“tiemao/911302307808371268/g_torsion/0_0”>>,#{},<<”{"dataPackageType":"g_torsion","siteCode":"91130230
7808371268","values":[{"extras":[{"data":"jUzDRG8cxETfS8FEb9jBRO1nw0Q8oshEYAXJRKzTzUSpU85EQ7XQRMWO0UQL7M9ENZPRRP1PzUTYR81ETSLGRDTnwkTGYsJEfwC+
RNR5vkT9w7hE9Sm9REHAuUTmirxEVm27RBZ5vkTB+cBE+THBRPTyxUTGYsJEOKXHRJ9DxUSx5cNE7vjDRPnfvERuJcBEWhi4RI+auESRNLVE02y0RMvyskTnMLREkUuzRNt3tkR99bpE8m63RJVbu0
Q"…>>},infinity,{#Fun<emqx_connector_mqtt.0.124205462>,[{fun emqx_resource_buffer_worker:handle_async_reply/2,[#{buffer_worker => <0.2636.0>,infligh
t_tid => #Ref<0.3258589376.2552102913.18607>,min_query => {query,undefined,,false,-576243564895627522},query_opts => #{inflight_tid => #Ref<0.325858
9376.2552102913.18607>,simple_query => false},request_ref => -576243579895372521,resource_id => <<“bridge:mqtt:tiemao-cloud”>>,worker_index => 2}]}]}}
,{publish,default,{mqtt_msg,0,false,false,undefined,<<“tiemao/911302307808371268/g_torsion/0_1”>>,#{},<<“{"dataPackageType":"g_torsion","siteCode
":"911302307808371268","values":[{"extras":[{"data":"Z4TLRCgy0ES37MtEtq3QRKvszUT939FEXXXVRBIm20Q5IuNEVTPeRIP84UTHReFEHQbjRP6l30RoVdxEcB/aRK7
J1kRoW9hE81HRRC8900Qhf89Em0fQRJHNzkS3SdVEysDXRGpK10QUyNxEGqPbRF/04UTwct9EnfbgRM9C4UT07+BEL6jgRAzz2US1UdxEk6rYREoM1kT6ptNED/zTRHVK1UTUHtREMjTYRDG61EQ15
9lEoafXROm”…>>},infinity,{#Fun<emqx_connector_mqtt.0.124205462>,[{fun emqx_resource_buffer_worker:handle_async_reply/2,[#{buffer_worker => <0.2636.0

,inflight_tid => #Ref<0.3258589376.2552102913.18607>,min_query => {query,undefined,,false,-576243564895433516},query_opts => #{inflight_tid => #Ref
<0.3258589376.2552102913.18607>,simple_query => false},request_ref => -576243579895324389,resource_id => <<“bridge:mqtt:tiemao-cloud”>>,worker_index =
2}]}]}},{publish,default,{mqtt_msg,0,false,false,undefined,<<“tiemao/911302307808371268/g_torsion/0_2”>>,#{},<<“{"dataPackageType":"g_torsion",
“siteCode":"911302307808371268","values":[{"extras":[{"data":"Z4qkRFi1o0R53KVE7YWlRDY1p0TjFa5EiIKxRHE7s0QimrNEoPu4RFCTuEQFJbpEhni9RGj5uEQ8E7
tEQ1i0RBtZsUTFc7BE1F+vRFb1rURaVqtEpBCwRBnLr0T3+K9ECHOwRFCTuEQb8rVEgEi7RNhjvERdFb5EswjBRPXzwUQC6bxEwLC9RNIIvURUxrlEAdC3RIe6uESRlbdEg9+4REvStURSybhEEse5
RGkEvERZX75E86n”…>>},infinity,{#Fun<emqx_connector_mqtt.0.124205462>,[{fun emqx_resource_buffer_worker:handle_async_reply/2,[#{buffer_worker => <0.2
636.0>,inflight_tid => #Ref<0.3258589376.2552102913.18607>,min_query => {query,undefined,,false,-576243564850214243},query_opts => #{inflight_tid =>
#Ref<0.3258589376.2552102913.18607>,simple_query => false},request_ref => -576243579850095620,resource_id => <<“bridge:mqtt:tiemao-cloud”>>,worker_in
dex => 2}]}]}},{publish,default,{mqtt_msg,0,false,false,undefined,<<“tiemao/911302307808371268/g_torsion/0_3”>>,#{},<<”{"dataPackageType":"g_torsio
n","siteCode":"911302307808371268","values":[{"extras":[{"data":"ABCsRAAYsERLNKtEkdqwRI/dr0RPwbNEtWS3RGbluETM1bpEaCa8RBZrwETNvrxEQiy+RIkPu
kTqPrlEKDm0RB3kskRAlLFEAaGsRBr8qUQT9KZEoWaqRFSjqUTQoapEEKytRFIlsEQag7VE3Ta2RDsIt0TAeLVEhrq3RGTot0QeDrhEt662RGLVsERyArNELVavRKUnrUSmzKxEBcmqRM5UrEQgB6x
EeWysRAxGq0QFgbF"…>>},infinity,{#Fun<emqx_connector_mqtt.0.124205462>,[{fun emqx_resource_buffer_worker:handle_async_reply/2,[#{buffer_worker => <0.
2636.0>,inflight_tid => #Ref<0.3258589376.2552102913.18607>,min_query => {query,undefined,,false,-576243564849982891},query_opts => #{inflight_tid =
#Ref<0.3258589376.2552102913.18607>,simple_query => false},request_ref => -576243579849907752,resource_id => <<“bridge:mqtt:tiemao-cloud”>>,worker_i
ndex => 2}]}]}},{publish,default,{mqtt_msg,0,false,false,undefined,<<“tiemao/911302307808371268/Online/13020901/Transfer/g_wavedata”>>,#{},<<“{"siteC
ode":"911302307808371268","measurePointId":"13020901-0-5-0-11","dataPackageType":"g_wavedata","dataSource":"doton","values":[{"ts":
1699113788000,"extras":[{"dataType":1,"name":"wave data","fs":1000,"sp":0,"fr":0,"data":[1.2601432,0.7485364,0.35435,0.4384988,1.08796
64,0.9811392,0.29884762,0.6434996,1.0017288,0.959356,0.5”…>>},infinity,{#Fun<emqx_connector_mqtt.0.124205462>,[{fun emqx_resource_buffer_worker:hand
le_async_reply/2,[#{buffer_worker => <0.2636.0>,inflight_tid => #Ref<0.3258589376.2552102913.18607>,min_query => {query,undefined,,false,-5762435646
01903310},query_opts => #{inflight_tid => #Ref<0.3258589376.2552102913.18607>,simple_query => false},request_ref => -576243579601516038,resource_id =>
<<“bridge:mqtt:tiemao-cloud”>>,worker_index => 2}]}]}},{publish,default,{mqtt_msg,0,false,false,undefined,<<“tiemao/911302307808371268/Online/1302090
1/Transfer/g_wavedata”>>,#{},<<“{"siteCode":"911302307808371268","measurePointId":"13020901-0-6-0-11","dataPackageType":"g_wavedata","dat
aSource":"doton","values":[{"ts":1699113788000,"extras":[{"dataType":1,"name":"wave data","fs":1000,"sp":0,"fr":0,"data":[0.550
3988,0.0341668,-0.3644956,-0.2770644,0.3540516,0.2955652,-0.427458,-0.1347276,0.225292,0.293”…>>},infinity,{#Fun<emqx_connector_mqtt.0.124205462>,[{
fun emqx_resource_buffer_worker:handle_async_reply/2,[#{buffer_worker => <0.2636.0>,inflight_tid => #Ref<0.3258589376.2552102913.18607>,min_query => {
query,undefined,,false,-576243563891549482},query_opts => #{inflight_tid => #Ref<0.3258589376.2552102913.18607>,simple_query => false},request_ref

emqx的版本5.0.24,目的端为5.1.2版本

这个日志还不是很全,只看到 MQTT 桥接进程断开但没有具体原因。可能需要更多的日志,你可以附一个日志文件上来。

另外建议你升级到 5.3 的最新版本,现在是 5.3.0,包含了大量的问题修复:

附件为日志
emqx.log.3.20231106.zip (1.4 MB)