hepyu commented on issue #12800: URL: https://github.com/apache/pulsar/issues/12800#issuecomment-968621606
补充4： 我查阅了2.8.1release的fix list，注意到了2.8.1的这个修复： [broker] Fix issue where Key_Shared consumers could get stuck #10920 https://github.com/apache/pulsar/pull/10920 然后我同样看了下问题分区的stats，和上述issue中的stats做对比，不是同一个现象，但确实有些问题： 1.consumers竟然是空的，也就是没有消费者，那肯定没有办法消费了吧？在issue#10920中consumers是有消费者的。 2.subscriptions下的msgBacklog和msgBacklogNoDelayed有值且相等且正确，但是backlogSize确实0，这个不对吧？  下附脱敏后的topic stats(只把订阅者名称改了，其余都保持现场)： ``` { "count" : 0, "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesInCounter" : 0, "msgInCounter" : 0, "bytesOutCounter" : 10241853528, "msgOutCounter" : 7697026, "averageMsgSize" : 0.0, "msgChunkPublished" : false, "storageSize" : 501755617, "backlogSize" : 501604741, "offloadedStorageSize" : 0, "publishers" : [ { "count" : 0, "accessMode" : "Shared", "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "chunkedMessageRate" : 0.0, "producerId" : 83, "producerNameOffset" : 133, "producerNameLength" : 25, "addressOffset" : 79, "addressLength" : 17, "connectedSinceOffset" : 96, "connectedSinceLength" : 32, "clientVersionOffset" : 128, "clientVersionLength" : 5, "stringBuffer" : "/10.0.45.29:411742021-11-15T13:18:47.778522+08:002.8.0pulsar-biz-cluster-29-150/10.0.45.29:411742021-11-15T13:18:47.778522+08:002.8.0pulsar-biz-cluster-29-150", "metadata" : { }, "address" : "/10.0.45.29:41174", "connectedSince" : "2021-11-15T13:18:47.778522+08:00", "clientVersion" : "2.8.0", "producerName" : "pulsar-biz-cluster-29-150" }, { "count" : 0, "accessMode" : "Shared", "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "chunkedMessageRate" : 0.0, "producerId" : 71, "producerNameOffset" : 135, "producerNameLength" : 25, "addressOffset" : 80, "addressLength" : 18, "connectedSinceOffset" : 98, "connectedSinceLength" : 32, "clientVersionOffset" : 130, "clientVersionLength" : 5, "stringBuffer" : "/10.0.44.204:493302021-11-15T13:23:34.155674+08:002.8.0pulsar-biz-cluster-29-168/10.0.44.204:493302021-11-15T13:23:34.155674+08:002.8.0pulsar-biz-cluster-29-168", "metadata" : { }, "address" : "/10.0.44.204:49330", "connectedSince" : "2021-11-15T13:23:34.155674+08:00", "clientVersion" : "2.8.0", "producerName" : "pulsar-biz-cluster-29-168" }, { "count" : 0, "accessMode" : "Shared", "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "chunkedMessageRate" : 0.0, "producerId" : 83, "producerNameOffset" : 135, "producerNameLength" : 25, "addressOffset" : 80, "addressLength" : 18, "connectedSinceOffset" : 98, "connectedSinceLength" : 32, "clientVersionOffset" : 130, "clientVersionLength" : 5, "stringBuffer" : "/10.0.47.110:590002021-11-15T13:18:45.181149+08:002.8.0pulsar-biz-cluster-29-129/10.0.47.110:590002021-11-15T13:18:45.181149+08:002.8.0pulsar-biz-cluster-29-129", "metadata" : { }, "address" : "/10.0.47.110:59000", "connectedSince" : "2021-11-15T13:18:45.181149+08:00", "clientVersion" : "2.8.0", "producerName" : "pulsar-biz-cluster-29-129" } ], "waitingPublishers" : 0, "subscriptions" : { "xxx-web" : { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesOutCounter" : 10241853528, "msgOutCounter" : 7697026, "msgRateRedeliver" : 0.0, "chunkedMessageRate" : 0, "msgBacklog" : 90862, "backlogSize" : 0, "msgBacklogNoDelayed" : 90862, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 0, "type" : "Key_Shared", "msgRateExpired" : 0.0, "totalMsgExpired" : 0, "lastExpireTimestamp" : 0, "lastConsumedFlowTimestamp" : 1636951642402, "lastConsumedTimestamp" : 0, "lastAckedTimestamp" : 0, "lastMarkDeleteAdvancedTimestamp" : 1636948251670, "consumers" : [ ], "isDurable" : true, "isReplicated" : false, "consumersAfterMarkDeletePosition" : { }, "nonContiguousDeletedMessagesRanges" : 46, "nonContiguousDeletedMessagesRangesSerializedSize" : 810, "durable" : true, "replicated" : false } }, "replication" : { }, "deduplicationStatus" : "Disabled", "nonContiguousDeletedMessagesRanges" : 46, "nonContiguousDeletedMessagesRangesSerializedSize" : 810 } ``` -- 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]
