liushiqi1001
liushiqi1001
a.log is goroutine function call
I've pinpointed the issue to this function—it's incredibly slow. What exactly does this function do? 
Yes, I reviewed the source code and found that the code responsible for "check interest" logic is extremely slow, which is blocking the entire program startup. We are using MQTT...
I want to monitor whether the MQTT consumers have received specific messages. We’ve noticed that sometimes there's a significant delay with MQTT, and occasionally, some consumers receive messages only after...
Is there a way to split these MQTT consumers into multiple streams?
> @liushiqi1001 Do your clients use retained messages? QOS2? Are you using a single server or a cluster? We are using MQTT with QoS 1, and we have a three-node...
I have another question. I have cleared all MQTT sessions using nats stream purge '$MQTT_sess' -f, which was a last resort. However, why are the consumer directories still present in...
 "What impact does this orphan message have? Will it affect the delivery of normal messages? We have 27k+ MQTT consumers, and it takes half an hour to start, which...
 What impact would skipping the $MQTT_msgs check have on MQTT?
> Are you a Synadia customer? no