AdrianPedziwiatr-TomTom commented on issue #22657:
URL: https://github.com/apache/pulsar/issues/22657#issuecomment-2102156283
Here are the statistics.
I collected them after a test. Not all messages were consumed (consumers for
some topics got hung up).
```
{
"msgRateIn" : 0.0,
"msgThroughputIn" : 0.0,
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"bytesInCounter" : 943097,
"msgInCounter" : 6052,
"bytesOutCounter" : 15027,
"msgOutCounter" : 109,
"averageMsgSize" : 0.0,
"msgChunkPublished" : false,
"storageSize" : 943097,
"backlogSize" : 934725,
"publishRateLimitedTimes" : 0,
"earliestMsgPublishTimeInBacklogs" : 0,
"offloadedStorageSize" : 0,
"lastOffloadLedgerId" : 0,
"lastOffloadSuccessTimeStamp" : 0,
"lastOffloadFailureTimeStamp" : 0,
"ongoingTxnCount" : 0,
"abortedTxnCount" : 0,
"committedTxnCount" : 0,
"publishers" : [ {
"accessMode" : "Shared",
"msgRateIn" : 0.0,
"msgThroughputIn" : 0.0,
"averageMsgSize" : 0.0,
"chunkedMessageRate" : 0.0,
"producerId" : 9,
"supportsPartialProducer" : false,
"metadata" : { },
"address" : "/10.240.0.18:42256",
"producerName" : "pulsar-3-11",
"connectedSince" : "2024-05-09T07:11:32.288324634Z",
"clientVersion" : "Pulsar-Java-v3.0.4"
}, {
"accessMode" : "Shared",
"msgRateIn" : 0.0,
"msgThroughputIn" : 0.0,
"averageMsgSize" : 0.0,
"chunkedMessageRate" : 0.0,
"producerId" : 14,
"supportsPartialProducer" : false,
"metadata" : { },
"address" : "/10.240.0.131:44020",
"producerName" : "pulsar-3-13",
"connectedSince" : "2024-05-09T07:11:32.28602009Z",
"clientVersion" : "Pulsar-Java-v3.0.4"
}, {
"accessMode" : "Shared",
"msgRateIn" : 0.0,
"msgThroughputIn" : 0.0,
"averageMsgSize" : 0.0,
"chunkedMessageRate" : 0.0,
"producerId" : 21,
"supportsPartialProducer" : false,
"metadata" : { },
"address" : "/10.240.0.18:37600",
"producerName" : "pulsar-3-17",
"connectedSince" : "2024-05-09T07:11:32.289208551Z",
"clientVersion" : "Pulsar-Java-v3.0.4"
}, {
"accessMode" : "Shared",
"msgRateIn" : 0.0,
"msgThroughputIn" : 0.0,
"averageMsgSize" : 0.0,
"chunkedMessageRate" : 0.0,
"producerId" : 20,
"supportsPartialProducer" : false,
"metadata" : { },
"address" : "/10.240.0.152:43668",
"producerName" : "pulsar-3-22",
"connectedSince" : "2024-05-09T07:11:32.315173653Z",
"clientVersion" : "Pulsar-Java-v3.0.4"
} ],
"waitingPublishers" : 0,
"subscriptions" : {
"pulsartestad10" : {
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"bytesOutCounter" : 15027,
"msgOutCounter" : 109,
"msgRateRedeliver" : 0.0,
"messageAckRate" : 0.0,
"chunkedMessageRate" : 0,
"msgBacklog" : 5777,
"backlogSize" : 934725,
"earliestMsgPublishTimeInBacklog" : 0,
"msgBacklogNoDelayed" : 5777,
"blockedSubscriptionOnUnackedMsgs" : false,
"msgDelayed" : 0,
"unackedMessages" : 0,
"type" : "Shared",
"msgRateExpired" : 0.0,
"totalMsgExpired" : 0,
"lastExpireTimestamp" : 0,
"lastConsumedFlowTimestamp" : 1715238695970,
"lastConsumedTimestamp" : 1715238695970,
"lastAckedTimestamp" : 1715238696259,
"lastMarkDeleteAdvancedTimestamp" : 1715238696259,
"consumers" : [ {
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"bytesOutCounter" : 2346,
"msgOutCounter" : 19,
"msgRateRedeliver" : 0.0,
"messageAckRate" : 0.0,
"chunkedMessageRate" : 0.0,
"consumerName" : "9a385",
"availablePermits" : -17,
"unackedMessages" : 0,
"avgMessagesPerEntry" : 3,
"blockedConsumerOnUnackedMsgs" : true,
"lastAckedTimestamp" : 1715238694438,
"lastConsumedTimestamp" : 1715238694116,
"lastConsumedFlowTimestamp" : 1715238694124,
"metadata" : { },
"address" : "/10.240.0.131:44036",
"connectedSince" : "2024-05-09T07:11:32.290486476Z",
"clientVersion" : "Pulsar-Java-v3.0.4",
"lastAckedTime" : "2024-05-09T07:11:34.438Z",
"lastConsumedTime" : "2024-05-09T07:11:34.116Z"
}, {
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"bytesOutCounter" : 1357,
"msgOutCounter" : 11,
"msgRateRedeliver" : 0.0,
"messageAckRate" : 0.0,
"chunkedMessageRate" : 0.0,
"consumerName" : "58a5f",
"availablePermits" : -10,
"unackedMessages" : 0,
"avgMessagesPerEntry" : 11,
"blockedConsumerOnUnackedMsgs" : true,
"lastAckedTimestamp" : 1715238693873,
"lastConsumedTimestamp" : 1715238692374,
"lastConsumedFlowTimestamp" : 1715238692409,
"metadata" : { },
"address" : "/10.240.0.131:44042",
"connectedSince" : "2024-05-09T07:11:32.291014886Z",
"clientVersion" : "Pulsar-Java-v3.0.4",
"lastAckedTime" : "2024-05-09T07:11:33.873Z",
"lastConsumedTime" : "2024-05-09T07:11:32.374Z"
}, {
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"bytesOutCounter" : 1476,
"msgOutCounter" : 12,
"msgRateRedeliver" : 0.0,
"messageAckRate" : 0.0,
"chunkedMessageRate" : 0.0,
"consumerName" : "c4fba",
"availablePermits" : -11,
"unackedMessages" : 0,
"avgMessagesPerEntry" : 12,
"blockedConsumerOnUnackedMsgs" : true,
"lastAckedTimestamp" : 1715238694112,
"lastConsumedTimestamp" : 1715238692413,
"lastConsumedFlowTimestamp" : 1715238692543,
"metadata" : { },
"address" : "/10.240.0.131:44008",
"connectedSince" : "2024-05-09T07:11:32.291343692Z",
"clientVersion" : "Pulsar-Java-v3.0.4",
"lastAckedTime" : "2024-05-09T07:11:34.112Z",
"lastConsumedTime" : "2024-05-09T07:11:32.413Z"
}, {
"msgRateOut" : 0.0,
"msgThroughputOut" : 0.0,
"bytesOutCounter" : 9848,
"msgOutCounter" : 67,
"msgRateRedeliver" : 0.0,
"messageAckRate" : 0.0,
"chunkedMessageRate" : 0.0,
"consumerName" : "cff0d",
"availablePermits" : -5,
"unackedMessages" : 0,
"avgMessagesPerEntry" : 2,
"blockedConsumerOnUnackedMsgs" : true,
"lastAckedTimestamp" : 1715238696259,
"lastConsumedTimestamp" : 1715238695970,
"lastConsumedFlowTimestamp" : 1715238695972,
"metadata" : { },
"address" : "/10.240.0.18:42270",
"connectedSince" : "2024-05-09T07:11:32.291622498Z",
"clientVersion" : "Pulsar-Java-v3.0.4",
"lastAckedTime" : "2024-05-09T07:11:36.259Z",
"lastConsumedTime" : "2024-05-09T07:11:35.97Z"
} ],
"isDurable" : true,
"isReplicated" : false,
"allowOutOfOrderDelivery" : false,
"consumersAfterMarkDeletePosition" : { },
"nonContiguousDeletedMessagesRanges" : 0,
"nonContiguousDeletedMessagesRangesSerializedSize" : 0,
"delayedMessageIndexSizeInBytes" : 0,
"subscriptionProperties" : { },
"filterProcessedMsgCount" : 0,
"filterAcceptedMsgCount" : 0,
"filterRejectedMsgCount" : 0,
"filterRescheduledMsgCount" : 0,
"durable" : true,
"replicated" : false
}
},
"replication" : { },
"deduplicationStatus" : "Enabled",
"nonContiguousDeletedMessagesRanges" : 0,
"nonContiguousDeletedMessagesRangesSerializedSize" : 0,
"delayedMessageIndexSizeInBytes" : 0,
"compaction" : {
"lastCompactionRemovedEventCount" : 0,
"lastCompactionSucceedTimestamp" : 0,
"lastCompactionFailedTimestamp" : 0,
"lastCompactionDurationTimeInMills" : 0
},
"ownerBroker" :
"pulsar-broker-2.pulsar-broker.default.svc.cluster.local:8080"
}
```
There are 4 consumers, each of them is ` "unackedMessages" : 0` and at the
same time `"blockedConsumerOnUnackedMsgs" : true`.
--
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]
