mouchar commented on issue #24322:
URL: https://github.com/apache/pulsar/issues/24322#issuecomment-3985327871
I found this open issue because I face the same problem.
In my case, these metrics:
```
pulsar_consumer_available_permits
pulsar_consumer_blocked_on_unacked_messages
pulsar_consumer_msg_ack_rate
pulsar_consumer_msg_rate_out
pulsar_consumer_msg_rate_redeliver
pulsar_consumer_msg_throughput_out
pulsar_consumer_unacked_messages
pulsar_out_bytes_total
pulsar_out_messages_total
```
are returned twice for the same combination of labels `(cluster, namespace,
topic, partition, subscription, consumer_name, consumer_id)`.
And there's one more thing what all duplicate instances have in common: All
are related to consumers of DLQ topics; maybe it's just coincicence, but it's
worth mentioning,
Here are stats for one of affected topic:
```json
{
"backlogSize": 0,
"msgInCounter": 0,
"msgOutCounter": 0,
"msgRateIn": 0,
"msgRateOut": 0,
"msgThroughputIn": 0,
"msgThroughputOut": 0,
"averageMsgSize": 0,
"storageSize": 0,
"publishers": [],
"subscriptions": {
"sql-executor.execution-dead-letter": {
"blockedSubscriptionOnUnackedMsgs": false,
"isReplicated": false,
"lastConsumedFlowTimestamp": 1772452931148,
"lastConsumedTimestamp": 0,
"lastAckedTimestamp": 0,
"msgRateOut": 0,
"msgThroughputOut": 0,
"msgRateRedeliver": 0,
"msgRateExpired": 0,
"msgBacklog": 0,
"msgBacklogNoDelayed": 0,
"msgDelayed": 0,
"unackedMessages": 0,
"type": "Shared",
"activeConsumerName": "",
"bytesOutCounter": 0,
"msgOutCounter": 0,
"messageAckRate": 0,
"chunkedMessageRate": 0,
"backlogSize": 0,
"earliestMsgPublishTimeInBacklog": 0,
"totalMsgExpired": 0,
"lastExpireTimestamp": 0,
"lastMarkDeleteAdvancedTimestamp": 0,
"consumers": [
{
"blockedConsumerOnUnackedMsgs": false,
"availablePermits": 1000,
"unackedMessages": 0,
"msgRateOut": 0,
"msgThroughputOut": 0,
"msgRateRedeliver": 0,
"consumerName": "select-dead-letter",
"bytesOutCounter": 0,
"msgOutCounter": 0,
"messageAckRate": 0,
"chunkedMessageRate": 0,
"avgMessagesPerEntry": 0,
"address": "/10.253.232.64:38572",
"connectedSince": "2026-03-02T12:00:54.249587526Z",
"clientVersion": "Pulsar-Java-v3.3.9",
"lastAckedTimestamp": 0,
"lastConsumedTimestamp": 0,
"lastConsumedFlowTimestamp": 1772452854250,
"metadata": {}
},
{
"blockedConsumerOnUnackedMsgs": false,
"availablePermits": 1000,
"unackedMessages": 0,
"msgRateOut": 0,
"msgThroughputOut": 0,
"msgRateRedeliver": 0,
"consumerName": "select-dead-letter",
"bytesOutCounter": 0,
"msgOutCounter": 0,
"messageAckRate": 0,
"chunkedMessageRate": 0,
"avgMessagesPerEntry": 0,
"address": "/10.253.229.39:40902",
"connectedSince": "2026-03-02T12:02:11.058802402Z",
"clientVersion": "Pulsar-Java-v3.3.9",
"lastAckedTimestamp": 0,
"lastConsumedTimestamp": 0,
"lastConsumedFlowTimestamp": 1772452931148,
"metadata": {}
}
],
"isDurable": true,
"allowOutOfOrderDelivery": false,
"consumersAfterMarkDeletePosition": {},
"nonContiguousDeletedMessagesRanges": 0,
"nonContiguousDeletedMessagesRangesSerializedSize": 0,
"delayedMessageIndexSizeInBytes": 0,
"subscriptionProperties": {},
"filterProcessedMsgCount": 0,
"filterAcceptedMsgCount": 0,
"filterRejectedMsgCount": 0,
"filterRescheduledMsgCount": 0
}
},
"replication": {},
"deduplicationStatus": "Disabled",
"topicCreationTimeStamp": 1758617068381
}
```
--
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]
