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

hangc0276 · srinath-ctds · commit 74014191a823 · 2024-12-10T09:41:34.000+05:30
(cherry picked from commit 59d4588) (cherry picked from commit 8168df1)
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
@@ -898,6 +898,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
`@@ -898,6 +898,7 @@ public ConsumerStatsImpl getStats() {`
`898`	`898`	`stats.unackedMessages = unackedMessages;`
`899`	`899`	`stats.blockedConsumerOnUnackedMsgs = blockedConsumerOnUnackedMsgs;`
`900`	`900`	`stats.avgMessagesPerEntry = getAvgMessagesPerEntry();`
	`901`	`+ stats.consumerName = consumerName;`
`901`	`902`	`if (readPositionWhenJoining != null) {`
`902`	`903`	`stats.readPositionWhenJoining = readPositionWhenJoining.toString();`
`903`	`904`	`}`