180254 commented on issue #22657: URL: https://github.com/apache/pulsar/issues/22657#issuecomment-2110491759
I added some multi-threading to the test to make it closer to how it is in the service, and I reproduced the problem also for larger values of maxUnackedMsgPerConsumer. Please see: https://github.com/180254/pulsar-issue-22657/commit/20050a50948159931ce1a61f4bff23a6eb494a61 (*test22657_3*, *test22657_3_moreconsumers*) v3.0.1: fails when [maxUnackedMsgPerConsumer=1,maxUnackedMsgPerSubscription=1], other variants ok v3.0.2: fails branch-3.0 (2da571e): fails ``` 2024-05-14T17:06:13,335 - INFO - [awaitility-thread:BrokerServiceTest] - ---- 2024-05-14T17:06:13,336 - INFO - [awaitility-thread:BrokerServiceTest] - subscriptionStats: SubscriptionStatsImpl(msgRateOut=0.0, msgThroughputOut=0.0, bytesOutCounter=744, msgOutCounter=40, msgRateRedeliver=0.0, messageAckRate=0.0, chunkedMessageRate=0, msgBacklog=0, backlogSize=-1, earliestMsgPublishTimeInBacklog=0, msgBacklogNoDelayed=0, blockedSubscriptionOnUnackedMsgs=false, msgDelayed=0, unackedMessages=0, type=Shared, activeConsumerName=null, msgRateExpired=0.0, totalMsgExpired=0, lastExpireTimestamp=0, lastConsumedFlowTimestamp=1715699172372, lastConsumedTimestamp=1715699172383, lastAckedTimestamp=1715699172386, lastMarkDeleteAdvancedTimestamp=1715699172386, consumers=[ConsumerStatsImpl(msgRateOut=0.0, msgThroughputOut=0.0, bytesOutCounter=744, msgOutCounter=40, msgRateRedeliver=0.0, messageAckRate=0.0, chunkedMessageRate=0.0, consumerName=2b07e, availablePermits=-39, unackedMessages=0, avgMessagesPerEntry=40, blockedConsumerOnUnackedMsgs=true, readPositionWhenJoining=nul l, addressOffset=0, addressLength=16, connectedSinceOffset=34, connectedSinceLength=35, clientVersionOffset=16, clientVersionLength=18, lastAckedTimestamp=1715699172386, lastConsumedTimestamp=1715699172383, lastConsumedFlowTimestamp=1715699172386, keyHashRanges=null, metadata={}, stringBuffer=/127.0.0.1:45914Pulsar-Java-v3.0.52024-05-14T17:06:12.371810907+02:00)], isDurable=true, isReplicated=false, allowOutOfOrderDelivery=false, keySharedMode=null, consumersAfterMarkDeletePosition={}, nonContiguousDeletedMessagesRanges=0, nonContiguousDeletedMessagesRangesSerializedSize=0, delayedMessageIndexSizeInBytes=0, bucketDelayedIndexStats={}, subscriptionProperties={}, filterProcessedMsgCount=0, filterAcceptedMsgCount=0, filterRejectedMsgCount=0, filterRescheduledMsgCount=0) 2024-05-14T17:06:13,336 - INFO - [awaitility-thread:BrokerServiceTest] - currentReceiverQueueSize: 1 2024-05-14T17:06:13,336 - INFO - [awaitility-thread:BrokerServiceTest] - numMessagesInQueue: 0 2024-05-14T17:06:13,336 - INFO - [awaitility-thread:BrokerServiceTest] - unackedMessagesSubscription: 0 2024-05-14T17:06:13,336 - INFO - [awaitility-thread:BrokerServiceTest] - blockedSubscriptionOnUnackedMsgs: false 2024-05-14T17:06:13,336 - INFO - [awaitility-thread:BrokerServiceTest] - unackedMessagesConsumer: 0 2024-05-14T17:06:13,336 - INFO - [awaitility-thread:BrokerServiceTest] - blockedConsumerOnUnackedMsgs: true 2024-05-14T17:06:13,336 - INFO - [awaitility-thread:BrokerServiceTest] - ---- ``` -- 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]
