(pulsar) branch master updated: [fix] [broker] Add consumer name for subscription stats (#23671)

[technoboy]

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

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 59d4588c192 [fix] [broker] Add consumer name for subscription stats 
(#23671)
59d4588c192 is described below

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

    [fix] [broker] Add consumer name for subscription stats (#23671)
---
 .../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 bcd29d86490..0baba13cc0b 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
@@ -977,6 +977,7 @@ public class Consumer {
         stats.unackedMessages = unackedMessages;
         stats.blockedConsumerOnUnackedMsgs = blockedConsumerOnUnackedMsgs;
         stats.avgMessagesPerEntry = getAvgMessagesPerEntry();
+        stats.consumerName = consumerName;
         if (readPositionWhenJoining != null) {
             stats.readPositionWhenJoining = readPositionWhenJoining.toString();
         }