teo
1
环境
- EMQX 版本:6.1.0
- 操作系统版本:docker
重现此问题的步骤
- 初始一段时间正常消费
- 突然从一个时间点后,消费者没再消费消息
- emqx错误日志如下
{“time”:“2026-02-02T00:56:20.662253+00:00”,“msg”:“mq_sub_handle_connect_error”,“meta”:{“username”:“node-sub”,“time”:1769993780662241,“subscriber_ref”:“#Ref<0.0.35512995.2962630970.2827812867.206574>”,“retry_interval”:1000,“report_cb”:“fun logger:format_otp_report/1”,“reason”:“{error,{failed_to_open_consumer_state,{error,recoverable,leader_unavailable}}}”,“pid”:“<0.2636741.0>”,“peername”:“115.227.23.215:54588”,“msg”:“mq_sub_handle_connect_error”,“mq”:“prod/rf/message”,“mfa”:“{emqx_mq_sub,handle_connect,2}”,“line”:156,“gl”:“<0.4240.0>”,“file”:“emqx_mq_sub.erl”,“clientid”:“prod-rf-message-21”},“level”:“error”}