Pulsar使用topic 的生产和消费状态

bin/pulsar-admin topics stats aa/astr/my-topic

# msgRateIn 表示 topic 级别生产速率，其单位是 msg/s

# msgThroughputIn 表示 topic 级别生产吞吐量，其单位是 byte/s

# msgRateOut 表示 topic 级别消费速率，其单位是 msg/s

# msgThroughputOut 表示 topic 级别消费吞吐量，其单位是 byte/s

# publishers 表示生产者信息，一下是部分信息

# "publishers":[

#                {

#                    "accessMode":"Shared",

#                    "msgRateIn":0,     #生产者级别生产速率 msg/s

#                    "msgThroughputIn":0,     #生产者级别生产吞吐量 byte/s

#                    "connectedSince":"2021-12-20T03:09:51.715569Z",

#                    "clientVersion":"2.8.1-hw-0.1.3",

#                    "producerName":"pulsar-2-3856",

#                    "address":"/10.244.3.58:38030"    #生产者的 IP 地址

#                }

#            ]

# subscriptions 表示订阅组信息，一下是部分信息

# "subscriptions":{

#                "test-pulsar-sb-name":{     #订阅组的名称

#                    "msgRateOut":0,    #订阅（消费组）级别消费速率 msg/s

#                    "msgThroughputOut":0,    #订阅（消费组）级别消费吞吐量 byte/s

#                    "msgBacklog":0,     #消息积压数

#                    "unackedMessages":0,     #订阅（消费组）级别 unack 消息数量

#                    "type":"Failover",     #订阅方式

#                    "consumers":[     #消费者列表，消费者创建成功才会在这体现

#                        {

#                            "msgRateOut":0,     #消费者级别消费速率 msg/s

#                            "msgThroughputOut":0,     #消费者级别消费吞吐量 byte/s

#                            "unackedMessages":0,     #消费者级别 unack 消息数量

#                            "address":"/10.244.3.28:58786"     #消费者的 IP 地址

#                        }

#                    ],

#                    "isDurable":true,

#                }

#            }

# partitions 表示分区信息，根据 partition 维度统计的数据。下面是部分信息

# "partitions":{

#        "persistent://public/default/test-topic-partition-0":{     #分区名

#            "msgRateIn":0,

#            "msgThroughputIn":0,

#            "msgRateOut":0,

#            "msgThroughputOut":0,

#            "publishers":[     #生产者

#                {

#                    "accessMode":"Shared",

#                    "msgRateIn":0,

#                    "msgThroughputIn":0,

#                    "connectedSince":"2021-12-20T03:09:51.715569Z",     #生产者建链时间

#                    "clientVersion":"2.8.1-hw-0.1.3",

#                    "producerName":"pulsar-2-3856",

#                    "address":"/10.244.3.58:38030"     #生产者的 IP 地址

#                }

#            ],

#            "waitingPublishers":0,

#            "subscriptions":{     #订阅信息

#                "test-pulsar-sb-name":{    #消费者的订阅组名

#                    "msgRateOut":0,

#                    "msgThroughputOut":0,

#                    "unackedMessages":0,   #partition 级别的 unack 消息数量

#                    "type":"Failover",

#                    "consumers":[     #消费者信息

#                        {

#                            "msgRateOut":0,

#                            "msgThroughputOut":0,

#                            "connectedSince":"2021-12-20T03:09:41.605318Z",     #消费者建链时间

#                            "address":"/10.244.3.28:58786"     #消费者的 IP 地址

#                        }

#                    ],

#                    "isDurable":true,

#                    "isReplicated":false,

#                    "allowOutOfOrderDelivery":false

#                }

#            }