chrisxrepo opened a new issue, #20885: URL: https://github.com/apache/pulsar/issues/20885
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version pulsar v2.10.4 pulsar-client-go v0.10.0 ### Minimal reproduce step consume partitioned topic in key_share mode ### What did you expect to see? consume all partition ok ### What did you see instead? some partition not consumed a moment laster ### Anything else? #partition stats# { "msgRateIn" : 299.14623782854187, "msgThroughputIn" : 1199004.8716131216, "msgRateOut" : 598.3290349303924, "msgThroughputOut" : 2398252.116510898, "bytesInCounter" : 142392513815, "msgInCounter" : 36861681, "bytesOutCounter" : 412619934835, "msgOutCounter" : 106927821, "averageMsgSize" : 4008.0894224728345, "msgChunkPublished" : false, "storageSize" : 69523398391, "backlogSize" : 14580076658, "publishRateLimitedTimes" : 0, "earliestMsgPublishTimeInBacklogs" : 0, "offloadedStorageSize" : 0, "lastOffloadLedgerId" : 0, "lastOffloadSuccessTimeStamp" : 0, "lastOffloadFailureTimeStamp" : 0, "publishers" : [ ... ], "waitingPublishers" : 0, "subscriptions" : { "GaiaReport-MainAccount-S" : { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesOutCounter" : 127814446522, "msgOutCounter" : 33199299, "msgRateRedeliver" : 0.0, "messageAckRate" : 0.0, "chunkedMessageRate" : 0, "msgBacklog" : 3610782, "backlogSize" : 0, "earliestMsgPublishTimeInBacklog" : 0, "msgBacklogNoDelayed" : 3610782, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 1, "type" : "Key_Shared", "msgRateExpired" : 0.0, "totalMsgExpired" : 0, "lastExpireTimestamp" : 1690370164653, "lastConsumedFlowTimestamp" : 1690357707596, "lastConsumedTimestamp" : 1690356135203, "lastAckedTimestamp" : 1690356136194, "lastMarkDeleteAdvancedTimestamp" : 1690356120613, "consumers" : [ { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesOutCounter" : 1604762, "msgOutCounter" : 408, "msgRateRedeliver" : 0.0, "messageAckRate" : 0.0, "chunkedMessageRate" : 0.0, "consumerName" : "databus:1690356048619", "availablePermits" : 592, "unackedMessages" : 0, "avgMessagesPerEntry" : 1, "blockedConsumerOnUnackedMsgs" : false, "readPositionWhenJoining" : "295144:32883", "lastAckedTimestamp" : 1690356135635, "lastConsumedTimestamp" : 1690356135203, "keyHashRanges" : [ "[14569000, 15087580]", "[28797888, 29576554]", "[34156182, 34840949]", "[37859811, 38153101]", "[39195531, 39884801]", "[87349777, 87966914]", "[114312033, 114617248]", "[120116118, 120344674]", "[158254559, 158780034]", "[163838853, 164464168]", "[172064081, 172280157]", "[182609786, 182647399]", "[218341875, 218471776]", "[236519897, 236589255]", "[251382485, 251723248]", "[319805304, 319808475]", "[322521694, 322545723]", "[330144182, 330869617]", "[359994902, 360029974]", "[374046897, 374801295]", "[383843690, 385915994]", "[385915995, 386024089]", "[428142676, 428533321]", "[428533322, 428801470]", "[488981887, 489047313]", "[491231636, 491653219]", "[508948319, 509648781]", "[510767661, 510993545]", "[520220887, 520236094]", "[532626531, 532757474]", "[553742798, 554564560]", "[561434134, 561812878]", "[564827666, 565314250]", "[636362347, 637523980]", "[662775942, 662784968]", "[662784969, 663833918]", "[681226165, 681422249]", "[716706384, 71 6827199]", "[726429862, 726966915]", "[736149386, 737449200]", "[740570159, 740700816]", "[756187178, 756639289]", "[802952328, 803101114]", "[836821749, 837186710]", "[897320445, 899060528]", "[909184200, 909785779]", "[942222891, 942418986]", "[943699085, 943961308]", "[946600537, 948699155]", "[966549327, 967214565]", "[972724070, 973275976]", "[973986491, 974152758]", "[1047682111, 1047933299]", "[1088039047, 1090038714]", "[1126435099, 1126603983]", "[1132165286, 1132341454]", "[1133308759, 1133851414]", "[1138133946, 1138244603]", "[1190739417, 1192002735]", "[1226298017, 1227420624]", "[1230145968, 1230344255]", "[1268050025, 1268083499]", "[1276149696, 1276668159]", "[1332821595, 1333517587]", "[1359189916, 1359409863]", "[1367750746, 1368403701]", "[1375915865, 1376821118]", "[1451029955, 1453528548]", "[1460468420, 1461233073]", "[1481668469, 1482073957]", "[1510703275, 1510811437]", "[1516010900, 1517032504]", "[1530146835, 1530414177]", "[1530414178, 1530454859]", "[1534 672611, 1534968467]", "[1599888590, 1600059246]", "[1605732170, 1605777291]", "[1617417646, 1618804868]", "[1648654760, 1648705925]", "[1648705926, 1649818147]", "[1671941252, 1672400106]", "[1685394282, 1685503341]", "[1730923921, 1731511146]", "[1754602157, 1754951411]", "[1755459520, 1756782027]", "[1759593916, 1759869051]", "[1817774685, 1818677996]", "[1824829206, 1825442180]", "[1846367092, 1846607687]", "[1924729765, 1925127985]", "[1932986396, 1933765537]", "[1967723821, 1968302312]", "[2020293300, 2020729966]", "[2054167875, 2055211810]", "[2064590906, 2064959894]", "[2064959895, 2066412876]", "[2071319303, 2071460016]", "[2071696699, 2073068466]", "[2096041346, 2096066919]", "[2140972966, 2142721470]" ], "metadata" : { }, "address" : "/10.168.254.189:46312", "connectedSince" : "2023-07-26T15:20:48.635+08:00" }, { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesOutCounter" : 600295, "msgOutCounter" : 150, "msgRateRedeliver" : 0.0, "messageAckRate" : 0.0, "chunkedMessageRate" : 0.0, "consumerName" : "databus:1690356092470", "availablePermits" : 850, "unackedMessages" : 0, "avgMessagesPerEntry" : 1, "blockedConsumerOnUnackedMsgs" : false, "readPositionWhenJoining" : "295144:42113", "lastAckedTimestamp" : 1690356135487, "lastConsumedTimestamp" : 1690356135203, "keyHashRanges" : [ "[192355, 1031292]", "[20618764, 20895202]", "[30302243, 30681403]", "[59347653, 59879799]", "[63337360, 63657068]", "[91075304, 91129124]", "[103619098, 103866888]", "[150390762, 152968456]", "[189964137, 191058976]", "[192797183, 193361282]", "[209470089, 209671462]", "[251723249, 253743655]", "[263520723, 263920915]", "[268137345, 268919464]", "[272274871, 272658325]", "[292754450, 294697745]", "[352195487, 352422983]", "[353727243, 354512472]", "[435227186, 435595046]", "[441527971, 441663024]", "[447229378, 447873641]", "[478983964, 480170600]", "[491653220, 492078815]", "[550075962, 551502626]", "[562333710, 564356607]", "[568256559, 569333919]", "[571259416, 571381589]", "[584264005, 585237045]", "[591992195, 592241848]", "[623827501, 625211355]", "[626045477, 628299237]", "[665141959, 666016536]", "[703904003, 703910538]", "[714122630, 714222217]", "[730556139, 730999334]", "[731749668, 731780277]", "[750025053, 750209448]", "[759001670, 75909 2744]", "[774143084, 774393436]", "[807581561, 809509803]", "[819380270, 820740994]", "[835538930, 836016289]", "[836016290, 836369581]", "[859418058, 861254461]", "[878189634, 879129279]", "[891394891, 892240020]", "[960603286, 960651544]", "[968357236, 968376916]", "[978519552, 979292861]", "[981093797, 981216194]", "[981844216, 982056691]", "[1067290348, 1067502067]", "[1122786850, 1122823366]", "[1129007591, 1129911499]", "[1181102255, 1181624683]", "[1185281049, 1185643512]", "[1195321990, 1195466677]", "[1196613715, 1197235496]", "[1199271598, 1199382789]", "[1204372154, 1204666675]", "[1209658745, 1210266963]", "[1211333437, 1211626164]", "[1219623255, 1219835802]", "[1225287522, 1225440801]", "[1239886212, 1240231613]", "[1243195458, 1244419041]", "[1287060728, 1287783010]", "[1294671621, 1295068965]", "[1295068966, 1297223788]", "[1300773373, 1301810978]", "[1311663786, 1312041050]", "[1372901906, 1373179941]", "[1393010516, 1393156868]", "[1394464904, 1395401397]", "[14087 03942, 1409457573]", "[1411241237, 1411251658]", "[1428643351, 1428884537]", "[1429431521, 1429960627]", "[1482073958, 1482842513]", "[1496373086, 1497397493]", "[1518141584, 1518269900]", "[1567231075, 1567797859]", "[1578970849, 1579274371]", "[1586693817, 1587341608]", "[1613337078, 1614621832]", "[1678657421, 1680431907]", "[1697536192, 1697923067]", "[1700212550, 1701301314]", "[1756952934, 1758711861]", "[1771699750, 1771890952]", "[1819570519, 1819648279]", "[1830613010, 1830855133]", "[1845209113, 1845995119]", "[1849355168, 1849597499]", "[1862780696, 1863982455]", "[1900266661, 1900873841]", "[1943731937, 1943968699]", "[1968302313, 1968483697]", "[1995941952, 1997328960]", "[2046156100, 2048749008]" ], "metadata" : { }, "address" : "/10.159.27.15:51470", "connectedSince" : "2023-07-26T15:21:32.487+08:00" },{...} ], "isDurable" : true, "isReplicated" : false, "allowOutOfOrderDelivery" : false, "keySharedMode" : "AUTO_SPLIT", "consumersAfterMarkDeletePosition" : { "databus:1690356135146" : "295144:47743", "databus:1690356342250" : "295144:47843", "databus:1690356345475" : "295144:47843", "databus:1690356346174" : "295144:47843", "databus:1690356348535" : "295144:47843", "databus:1690356348621" : "295144:47843", "databus:1690356350203" : "295144:47843", "databus:1690356350606" : "295144:47843", "databus:1690356359696" : "295144:47843", "databus:1690356367831" : "295144:47843", "databus:1690356368105" : "295144:47843", "databus:1690356372427" : "295144:47843", "databus:1690356381018" : "295144:47843", "databus:1690356386616" : "295144:47843", "databus:1690356387345" : "295144:47843", "databus:1690356388692" : "295144:47843", "databus:1690356393673" : "295144:47843", "databus:1690356397119" : "295144:47843", "databus:1690356399073" : "295144:47843", "databus:1690356406633" : "295144:47843", "databus:1690356410442" : "295144:47843", "databus:1690356418686" : "295144:47843", "databus:1690356429882" : "295144:47843", "databus:1690357707535" : "295144:47843" }, "nonContiguousDeletedMessagesRanges" : 5, "nonContiguousDeletedMessagesRangesSerializedSize" : 100, "subscriptionProperties" : { }, "durable" : true, "replicated" : false } }, "replication" : { }, "deduplicationStatus" : "Disabled", "nonContiguousDeletedMessagesRanges" : 138, "nonContiguousDeletedMessagesRangesSerializedSize" : 2760, "compaction" : { "lastCompactionRemovedEventCount" : 0, "lastCompactionSucceedTimestamp" : 0, "lastCompactionFailedTimestamp" : 0, "lastCompactionDurationTimeInMills" : 0 } } ### Are you willing to submit a PR? - [ ] I'm willing to submit a PR! -- 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]
