francisoliverlee commented on issue #947: URL: https://github.com/apache/rocketmq-client-go/issues/947#issuecomment-1439392426
> the queue's messages span too long, so do flow control" 一般的， 有这种日志 > 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 表示消息消费消费太慢，本地缓存消息没有被及时消费，引起client的pull线程挂起，这个也可以成为 “背压机制” 代码如下：https://github.com/apache/rocketmq-client-go/blob/26142da1b88ef22ac018138c724f5d4f48059da3/consumer/push_consumer.go#L715-L729 建议记录下本地消费耗时，以此来确认下是客户端背压机制有问题， 还是消费慢。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
