hepyu commented on issue #12800: URL: https://github.com/apache/pulsar/issues/12800#issuecomment-968625204
补充5: 顺着补充4， 我查看了这个topic其他正常的分区，正常分区的stats是： 1.consumers有消费者实例，正确。 2.subscriptions下的msgBacklog和msgBacklogNoDelayed，backlogSize有值且相等且正确，都是0。  也就是说，在这种场景下，somehow的未知原因会导致严重堆积/不均衡的分区会丢失自己的consumer? 下附脱敏后的topic stats(只把订阅者名称改了，其余都保持现场)： ``` { "count" : 0, "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesInCounter" : 0, "msgInCounter" : 0, "bytesOutCounter" : 0, "msgOutCounter" : 0, "averageMsgSize" : 0.0, "msgChunkPublished" : false, "storageSize" : 0, "backlogSize" : 0, "offloadedStorageSize" : 0, "publishers" : [ { "count" : 0, "accessMode" : "Shared", "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "chunkedMessageRate" : 0.0, "producerId" : 80, "producerNameOffset" : 133, "producerNameLength" : 25, "addressOffset" : 79, "addressLength" : 17, "connectedSinceOffset" : 96, "connectedSinceLength" : 32, "clientVersionOffset" : 128, "clientVersionLength" : 5, "stringBuffer" : "/10.0.45.29:519842021-11-15T13:18:47.778107+08:002.8.0pulsar-biz-cluster-27-792/10.0.45.29:519842021-11-15T13:18:47.778107+08:002.8.0pulsar-biz-cluster-27-792", "metadata" : { }, "address" : "/10.0.45.29:51984", "connectedSince" : "2021-11-15T13:18:47.778107+08:00", "clientVersion" : "2.8.0", "producerName" : "pulsar-biz-cluster-27-792" }, { "count" : 0, "accessMode" : "Shared", "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "chunkedMessageRate" : 0.0, "producerId" : 68, "producerNameOffset" : 135, "producerNameLength" : 25, "addressOffset" : 80, "addressLength" : 18, "connectedSinceOffset" : 98, "connectedSinceLength" : 32, "clientVersionOffset" : 130, "clientVersionLength" : 5, "stringBuffer" : "/10.0.44.204:424662021-11-15T13:23:34.155559+08:002.8.0pulsar-biz-cluster-27-829/10.0.44.204:424662021-11-15T13:23:34.155559+08:002.8.0pulsar-biz-cluster-27-829", "metadata" : { }, "address" : "/10.0.44.204:42466", "connectedSince" : "2021-11-15T13:23:34.155559+08:00", "clientVersion" : "2.8.0", "producerName" : "pulsar-biz-cluster-27-829" }, { "count" : 0, "accessMode" : "Shared", "msgRateIn" : 0.0, "msgThroughputIn" : 0.0, "averageMsgSize" : 0.0, "chunkedMessageRate" : 0.0, "producerId" : 80, "producerNameOffset" : 135, "producerNameLength" : 25, "addressOffset" : 80, "addressLength" : 18, "connectedSinceOffset" : 98, "connectedSinceLength" : 32, "clientVersionOffset" : 130, "clientVersionLength" : 5, "stringBuffer" : "/10.0.47.110:367542021-11-15T13:18:45.180869+08:002.8.0pulsar-biz-cluster-27-740/10.0.47.110:367542021-11-15T13:18:45.180869+08:002.8.0pulsar-biz-cluster-27-740", "metadata" : { }, "address" : "/10.0.47.110:36754", "connectedSince" : "2021-11-15T13:18:45.180869+08:00", "clientVersion" : "2.8.0", "producerName" : "pulsar-biz-cluster-27-740" } ], "waitingPublishers" : 0, "subscriptions" : { "xxx-web" : { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesOutCounter" : 0, "msgOutCounter" : 0, "msgRateRedeliver" : 0.0, "chunkedMessageRate" : 0, "msgBacklog" : 0, "backlogSize" : 0, "msgBacklogNoDelayed" : 0, "blockedSubscriptionOnUnackedMsgs" : false, "msgDelayed" : 0, "unackedMessages" : 0, "type" : "Key_Shared", "msgRateExpired" : 0.0, "totalMsgExpired" : 0, "lastExpireTimestamp" : 0, "lastConsumedFlowTimestamp" : 1636949155301, "lastConsumedTimestamp" : 0, "lastAckedTimestamp" : 0, "lastMarkDeleteAdvancedTimestamp" : 0, "consumers" : [ { "msgRateOut" : 0.0, "msgThroughputOut" : 0.0, "bytesOutCounter" : 0, "msgOutCounter" : 0, "msgRateRedeliver" : 0.0, "chunkedMessageRate" : 0.0, "consumerName" : "8d143", "availablePermits" : 1000, "unackedMessages" : 0, "avgMessagesPerEntry" : 1000, "blockedConsumerOnUnackedMsgs" : false, "readPositionWhenJoining" : "320266:0", "addressOffset" : 53, "addressLength" : 16, "connectedSinceOffset" : 69, "connectedSinceLength" : 32, "clientVersionOffset" : 101, "clientVersionLength" : 5, "lastAckedTimestamp" : 0, "lastConsumedTimestamp" : 0, "keyHashRanges" : [ "[0, 65536]" ], "metadata" : { }, "stringBuffer" : "/10.0.36.1:501262021-11-15T12:05:51.210651+08:002.8.0/10.0.36.1:501262021-11-15T12:05:51.210651+08:002.8.0", "address" : "/10.0.36.1:50126", "connectedSince" : "2021-11-15T12:05:51.210651+08:00", "clientVersion" : "2.8.0" } ], "isDurable" : true, "isReplicated" : false, "consumersAfterMarkDeletePosition" : { }, "nonContiguousDeletedMessagesRanges" : 0, "nonContiguousDeletedMessagesRangesSerializedSize" : 0, "durable" : true, "replicated" : false } }, "replication" : { }, "deduplicationStatus" : "Disabled", "nonContiguousDeletedMessagesRanges" : 0, "nonContiguousDeletedMessagesRangesSerializedSize" : 0 } ``` -- 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]
