[ROCKETMQ-294] Do flow control on the number and size dimensions when pull message

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 4.2.0
• Component/s: rocketmq-client
• Assignee: Xinyu Zhou
• Reporter: Xinyu Zhou
• Created: 25/Sep/17 07:53
• Updated: 13/Dec/17 12:24
• Resolved: 13/Dec/17 12:24

Description

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.

Issue Links

• duplicates: ROCKETMQ-106 Add flow control on topic level
• links to: GitHub Pull Request #171