After upgrading from Pulsar-2.7 to >= Pulsar-2.10 broker, broker is not considering various broker configuration threshold and one of them is maxUnackedMessagesPerSubscription. We have broker configured with MaxUnackedMessagesPerSubscription=200000 and after sub reaches 200K unack messages, broker blocks the dispatching. It was working fine till broker-2.7 but it stopped working after upgrading to Pulsar-2.10 and higher version.
subscriptions" : {
"UnackMsgConsumersSubscription" : {
"msgRateOut" : 41.66667806597534,
"msgThroughputOut" : 63924.01748854578,
"bytesOutCounter" : 9813637567183,
"msgOutCounter" : 6346168888,
"msgRateRedeliver" : 1825.0005374626583,
"chuckedMessageRate" : 0,
"msgBacklog" : 63122123,
"backlogSize" : 0,
"msgBacklogNoDelayed" : 63122123,
"blockedSubscriptionOnUnackedMsgs" : false,
"msgDelayed" : 0,
"unackedMessages" : 614260,
"type" : "Shared",
"msgRateExpired" : 0.0,
"totalMsgExpired" : 0,
"lastExpireTimestamp" : 0,
"lastConsumedFlowTimestamp" : 1712610077925,
"lastConsumedTimestamp" : 1712610077938,
"lastAckedTimestamp" : 1712610088862,
"lastMarkDeleteAdvancedTimestamp" : 1712609791878,
"consumers" : [ {
"msgRateOut" : 41.66667806597534,
"msgThroughputOut" : 63924.01748854578,
"bytesOutCounter" : 5106838658,
"msgOutCounter" : 3324500,
"msgRateRedeliver" : 1825.0005374626583,
"chuckedMessageRate" : 0.0,
"consumerName" : "0f455",
"availablePermits" : 0,
"unackedMessages" : 614260,
"avgMessagesPerEntry" : 1,
"blockedConsumerOnUnackedMsgs" : false,
"lastAckedTimestamp" : 1712610088862,
"lastConsumedTimestamp" : 1712610077938,
"metadata" : { },
"connectedSince" : "2024-04-08T20:52:27.525995Z",
Search before asking
Read release policy
Version
After upgrading from Pulsar-2.7 to >= Pulsar-2.10 broker, broker is not considering various broker configuration threshold and one of them is
maxUnackedMessagesPerSubscription. We have broker configured withMaxUnackedMessagesPerSubscription=200000and after sub reaches 200K unack messages, broker blocks the dispatching. It was working fine till broker-2.7 but it stopped working after upgrading to Pulsar-2.10 and higher version.Minimal reproduce step
maxUnackedMessagesPerSubscription=200000What did you expect to see?
Broker should follow max threshold for various resources
What did you see instead?
Broker is not following max threshold for various resources
Anything else?
No response
Are you willing to submit a PR?