mqx中数据桥接数据一直发不出去,已缓存中有好多消息,重启一下源端的emqx又可以发送数据了
[error] crasher: initial call: emqtt:init/1, pid: <0.1049.46>, registered_name: [], exit: {closed,[{gen_statem,loop_state_callback_result,11,[{file,“gen_statem.erl”},{line,1397}]},{proc_lib,init_p_do_apply,3,[{file,“proc_lib.erl”},{line,226}]}]}, ancestors: [emqx_connector_mqtt,emqx_connector_sup,<0.2652.0>], message_queue_len: 103, messages: [{publish,default,{mqtt_msg,0,false,false,undefined,<<“tiemao/91410481706575279U/Online/41048101/Transfer/g_wavedata”>>,#{},<<“{"siteCode":"91410481706575279U","dataPackageType":"g_wavedata","measurePointId":"41048101-0-1-0-11","values":[{"ts":1690568233000,"telemetry":{"value":0.27882951,"mpType":112}}]}”>>},infinity,{#Fun<emqx_connector_mqtt.0.124205462>,[{fun emqx_resource_buffer_worker:handle_async_reply/2,[#{buffer_worker => <0.2663.0>,inflight_tid =>
2023-07-29T02:28:10.259790+08:00 [error] Supervisor:
2023-07-29T02:28:10.259819+08:00 [info] msg: async_worker_died, mfa: emqx_resource_buffer_worker:running/3, line: 231, reason: closed, state: running
2023-07-29T02:28:10.244606+08:00 [error] crasher: initial call