complone commented on issue #71: URL: https://github.com/apache/rocketmq-eventbridge/issues/71#issuecomment-1510646382
The formula for calculating the current production and consumption speed is as follows: Production speed: quenes * PullBatchSize * 1000/pullInterval PullBatchSize Single pull quantity, Rocketmq single queue pull quantity at the same time, you can modify the maximum value is generally 32, if you need to expand again, you need to adjust the service parameters pullInterval is the interval of a single pull, the interval time for each pull message of Rocketmq, the default value is 0 no interval, in milliseconds, and 1000 is one second Quene is the number of queues, which is related to the number of brokers. For example, if the broker is 2 masters, each master and two slaves are set, and each broker has 8 queues, then there are 16 queues. Consumption speed: the amount of messages being consumed / the amount of unconsumed messages + the amount of messages being consumed + the amount of messages waiting to be pulled The amount of unconsumed messages ConsumerLag = MaxOffset - consumerOffset Amount of messages being consumed InflightMessageCount = PullOffset - ConsumerOffset Amount of messages waiting to be pulled AvaliableMessageCount = MaxOffset- PullOffset I will coordinate whether the upstream and downstream ConnectRecord records are refreshed according to the speed of the two -- 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]
