[fix] [broker] Add consumer name for subscription stats (#23671)

hangc0276 · lhotari · commit 7669f8668234 · 2024-12-07T01:29:19.000+02:00
(cherry picked from commit 59d4588)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
@@ -977,6 +977,7 @@ public ConsumerStatsImpl getStats() {
         stats.unackedMessages = unackedMessages;
         stats.blockedConsumerOnUnackedMsgs = blockedConsumerOnUnackedMsgs;
         stats.avgMessagesPerEntry = getAvgMessagesPerEntry();
+        stats.consumerName = consumerName;
         if (readPositionWhenJoining != null) {
             stats.readPositionWhenJoining = readPositionWhenJoining.toString();
         }

Original file line number	Diff line number	Diff line change
`@@ -977,6 +977,7 @@ public ConsumerStatsImpl getStats() {`
`977`	`977`	`stats.unackedMessages = unackedMessages;`
`978`	`978`	`stats.blockedConsumerOnUnackedMsgs = blockedConsumerOnUnackedMsgs;`
`979`	`979`	`stats.avgMessagesPerEntry = getAvgMessagesPerEntry();`
	`980`	`+ stats.consumerName = consumerName;`
`980`	`981`	`if (readPositionWhenJoining != null) {`
`981`	`982`	`stats.readPositionWhenJoining = readPositionWhenJoining.toString();`
`982`	`983`	`}`