You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
First I produce 1k msg to broker, then I run the examples/consumer/pull/pull.go code with minor changes (only start one goroutine to consume), just like
First I produce 1k msg to broker, then I run the examples/consumer/pull/pull.go code with minor changes (only start one goroutine to consume), just like
There the consume rate is very slow, every pull will block about 25s. But if modify the suspend param to false at
rocketmq-client-go/consumer/pull_consumer.go
Line 445 in f4875c1
The text was updated successfully, but these errors were encountered: