still consumption blocked after issue #944

I used the commit: [f3349bd](https://github.com/apache/rocketmq-client-go/commit/f3349bdbb4dbcf9a7481563cb0fc3dd3d3ce3985) which says it fixed the push consumer blocked issue [#944](https://github.com/apache/rocketmq-client-go/pull/944). But in my experience, consumer is still blocked while rocket mq actually has newest msg produced.

some logs like this:

```
time="2022-10-14T15:28:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:28:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=PULL_RT
time="2022-10-14T15:28:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=PULL_RT
time="2022-10-14T15:28:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=CONSUME_RT
time="2022-10-14T15:28:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=CONSUME_RT
time="2022-10-14T15:28:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=CONSUME_OK_TPS
time="2022-10-14T15:28:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=CONSUME_OK_TPS
time="2022-10-14T15:28:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=PULL_TPS
time="2022-10-14T15:28:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=PULL_TPS
time="2022-10-14T15:28:10Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=0, nextOffset=2035]" flowControlTimes=0 maxOffset=2034 maxSpan=1030 minOffset=1004
time="2022-10-14T15:28:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:28:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:28:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:28:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:28:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:28:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:28:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:28:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:28:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:28:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:28:23Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=0, nextOffset=2035]" flowControlTimes=0 maxOffset=2034 maxSpan=1030 minOffset=1004
time="2022-10-14T15:28:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:28:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:28:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:28:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:28:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:28:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:28:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:28:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:28:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:28:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:28:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:28:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:28:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:28:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:28:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:28:36Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=0, nextOffset=2035]" flowControlTimes=0 maxOffset=2034 maxSpan=1030 minOffset=1004
time="2022-10-14T15:28:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:28:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:28:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:28:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:28:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:28:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:28:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:28:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:28:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:28:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:28:48Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=0, nextOffset=2035]" flowControlTimes=0 maxOffset=2034 maxSpan=1030 minOffset=1004
time="2022-10-14T15:28:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:28:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:28:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:28:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:28:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:28:54Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:28:54Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:28:54Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:28:54Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:28:54Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:28:59Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:28:59Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:28:59Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:28:59Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:28:59Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:01Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=2, nextOffset=2099]" flowControlTimes=0 maxOffset=2098 maxSpan=1142 minOffset=956
time="2022-10-14T15:29:04Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:04Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:04Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:04Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:04Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=CONSUME_OK_TPS
time="2022-10-14T15:29:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=CONSUME_OK_TPS
time="2022-10-14T15:29:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=PULL_RT
time="2022-10-14T15:29:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=PULL_RT
time="2022-10-14T15:29:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=PULL_TPS
time="2022-10-14T15:29:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=PULL_TPS
time="2022-10-14T15:29:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=CONSUME_RT
time="2022-10-14T15:29:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=CONSUME_RT
time="2022-10-14T15:29:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:14Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=2, nextOffset=2099]" flowControlTimes=0 maxOffset=2098 maxSpan=1142 minOffset=956
time="2022-10-14T15:29:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:27Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=2, nextOffset=2099]" flowControlTimes=0 maxOffset=2098 maxSpan=1142 minOffset=956
time="2022-10-14T15:29:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:39Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=2, nextOffset=2099]" flowControlTimes=0 maxOffset=2098 maxSpan=1142 minOffset=956
time="2022-10-14T15:29:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:52Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=2, nextOffset=2099]" flowControlTimes=0 maxOffset=2098 maxSpan=1142 minOffset=956
time="2022-10-14T15:29:54Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:54Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:29:54Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:54Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:54Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:59Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:29:59Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:29:59Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:29:59Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:29:59Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:04Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:30:04Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:30:04Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:04Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:30:04Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:30:05Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=1, nextOffset=2836]" flowControlTimes=0 maxOffset=2835 maxSpan=1852 minOffset=983
time="2022-10-14T15:30:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=PULL_RT
time="2022-10-14T15:30:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=CONSUME_OK_TPS
time="2022-10-14T15:30:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=PULL_TPS
time="2022-10-14T15:30:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=PULL_TPS
time="2022-10-14T15:30:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=CONSUME_OK_TPS
time="2022-10-14T15:30:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=PULL_RT
time="2022-10-14T15:30:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey=rocket_mq_test@spot_quote_kline_test statsName=CONSUME_RT
time="2022-10-14T15:30:09Z" level=info msg="Stats In One Minute." AVGPT=0 SUM=0 TPS=0.00 statsKey="%RETRY%spot_quote_kline_test@spot_quote_kline_test" statsName=CONSUME_RT
time="2022-10-14T15:30:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:30:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:30:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:30:09Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:30:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:30:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:30:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:30:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:30:14Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:17Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=2, nextOffset=2099]" flowControlTimes=0 maxOffset=2098 maxSpan=1142 minOffset=956
time="2022-10-14T15:30:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:30:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:30:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:30:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:30:19Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:30:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:30:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:30:24Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:30:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:30:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:30:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:30:29Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:30:30Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=0, nextOffset=2035]" flowControlTimes=0 maxOffset=2034 maxSpan=1030 minOffset=1004
time="2022-10-14T15:30:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:30:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:30:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:30:34Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:30:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:30:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:30:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:30:39Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:30:43Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=0, nextOffset=2035]" flowControlTimes=0 maxOffset=2034 maxSpan=1030 minOffset=1004
time="2022-10-14T15:30:43Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=1, nextOffset=2836]" flowControlTimes=0 maxOffset=2835 maxSpan=1852 minOffset=983
time="2022-10-14T15:30:43Z" level=warning msg="the queue's messages span too long, so do flow control" ConsumeConcurrentlyMaxSpan=1000 PullRequest="[ConsumerGroup: spot_quote_kline_test, Topic: rocket_mq_test, MessageQueue: brokerName=rocketmq-internal-0, queueId=3, nextOffset=2407]" flowControlTimes=0 maxOffset=2406 maxSpan=1405 minOffset=1001
time="2022-10-14T15:30:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:30:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:30:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:30:44Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
time="2022-10-14T15:30:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=1004
time="2022-10-14T15:30:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=1]" consumerGroup=spot_quote_kline_test offset=983
time="2022-10-14T15:30:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=2]" consumerGroup=spot_quote_kline_test offset=956
time="2022-10-14T15:30:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=rocket_mq_test, brokerName=rocketmq-internal-0, queueId=3]" consumerGroup=spot_quote_kline_test offset=1001
time="2022-10-14T15:30:49Z" level=info msg="update offset to broker success" MessageQueue="MessageQueue [topic=%RETRY%spot_quote_kline_test, brokerName=rocketmq-internal-0, queueId=0]" consumerGroup=spot_quote_kline_test offset=221
```

then, after some minutes, the client continue consumed out new msg.

For short, the client do the loop: consumed some msg ---> blocked for a period of time ----> continue consumed out msg ----> blocked for a period of time ---> continue consumed out msg...

PS:
1. rocket mq always has new msg produced.
2. consumer just print the msg received, no other logics.

consumer code like this:

```
c, err := rocketmq.NewPushConsumer(
consumer.WithGroupName(group),
consumer.WithConsumeFromWhere(consumer.ConsumeFromLastOffset),
consumer.WithRetry(3),
consumer.WithNsResolver(primitive.NewEnvResolver()))
if err != nil {
panic(err)
}

if err := c.Subscribe(topic, consumer.MessageSelector{}, h.OnConsumeMessage); err != nil {
panic(err)
}

// Note: start after subscribe
if err := c.Start(); err != nil {
panic(err)
}
```

UPDATED:
when produced 1 msg per second, the block issue didn't happen.
when produced 10 msg per second, the block issue always happen.

WHY:
1. v2.1.1 has a bug which was fixed by commit [ffd72416](https://github.com/apache/rocketmq-client-go/commit/ffd72416) in issue #886, and push consumer can normally consume msg in commit [ffd72416](https://github.com/apache/rocketmq-client-go/commit/ffd72416) .
2. the bug sources from [ffd72416](https://github.com/apache/rocketmq-client-go/commit/ffd72416) to [f3349bdb](https://github.com/apache/rocketmq-client-go/commit/f3349bdb)