[ 
https://issues.apache.org/jira/browse/ROCKETMQ-294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16178955#comment-16178955
 ] 

ASF GitHub Bot commented on ROCKETMQ-294:
-----------------------------------------

Github user coveralls commented on the issue:

    https://github.com/apache/incubator-rocketmq/pull/171
  
    
    [![Coverage 
Status](https://coveralls.io/builds/13416107/badge)](https://coveralls.io/builds/13416107)
    
    Coverage increased (+0.2%) to 38.988% when pulling 
**8878a21e2d0a87ac0d1ae59483eabcc34fdafb07 on zhouxinyu:ROCKETMQ-294** into 
**5ac45fc56da44e1244d2c0a15522debe9ed820a1 on apache:develop**.



> Do flow control on the number and size dimensions when pull message
> -------------------------------------------------------------------
>
>                 Key: ROCKETMQ-294
>                 URL: https://issues.apache.org/jira/browse/ROCKETMQ-294
>             Project: Apache RocketMQ
>          Issue Type: Improvement
>          Components: rocketmq-client
>            Reporter: yukon
>            Assignee: yukon
>             Fix For: 4.2.0-incubating
>
>
> *Motivations*
> Current flow control strategy only support on Queue level, each message queue 
> can cache 1000 message by default. 
> When lots of message queue are assigned to one consumer instance, the 
> consumer will cache too many messages, may cause OOM exception.
> On the other hand, only control the message amount is not enough, should 
> support do flow control on the number and size dimensions, on Topic and Queue 
> level.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to