Uploaded image for project: 'Apache RocketMQ'
  1. Apache RocketMQ
  2. ROCKETMQ-294

Do flow control on the number and size dimensions when pull message

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 4.2.0
    • Component/s: rocketmq-client
    • Labels:
      None

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Yukon yukon
                Reporter:
                Yukon yukon
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: