(pulsar) 01/03: [fix] [broker] Add consumer name for subscription stats (#23671)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 8168df14987ec6cd6b932f0ea7793353124f9737
Author: Hang Chen <chenh...@apache.org>
AuthorDate: Wed Dec 4 10:01:44 2024 +0800

    [fix] [broker] Add consumer name for subscription stats (#23671)
    
    (cherry picked from commit 59d4588c1924df6e6a5e9eb9c525f6db0beeddf4)
---
 .../src/main/java/org/apache/pulsar/broker/service/Consumer.java         | 1 +
 1 file changed, 1 insertion(+)

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
index 96947dc2cb3..dbb594cce31 100644
--- 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
@@ -886,6 +886,7 @@ public class Consumer {
         stats.unackedMessages = unackedMessages;
         stats.blockedConsumerOnUnackedMsgs = blockedConsumerOnUnackedMsgs;
         stats.avgMessagesPerEntry = getAvgMessagesPerEntry();
+        stats.consumerName = consumerName;
         if (readPositionWhenJoining != null) {
             stats.readPositionWhenJoining = readPositionWhenJoining.toString();
         }