manjupriya-ar opened a new issue #9254:
URL: https://github.com/apache/pulsar/issues/9254
#### Expected behavior
The partitioned-stats API returns the number of messages that are yet to be
acknowledged at each subscription level. In addition to that, we need the
number of message bytes [total size of the messages] that are yet to
acknowledged at each subscription level.
#### Actual behavior
At present partitioned-stats returns the number of messages that are yet to
acknowledged.[msgBacklog parameter at subscription level]
./pulsar-admin topics partitioned-stats
persistent://public/default/sysresmetrics33
{
"averageMsgSize" : 0.0
"backlogSize" : 300,
"publishers" : [ ],
"subscriptions" : {
"0_itom_di_scheduler_provider_default_sysresmetrics33" : {
"msgBacklog" : 2
},
"2_itom_di_scheduler_provider_default_sysresmetrics33" : {
"msgBacklog" : 3,
},
"1_itom_di_scheduler_provider_default_sysresmetrics33" : {
"msgBacklog" : 4,
}
},
"replication" : { },
"metadata" : {
"partitions" : 3
},
"partitions" : { }
}
##### Expected Output for partitioned-stats
In addition to number of messages that are yet to be acknowledged at each
subscription level, number of bytes that are yet to acknowledged needs to be
added. Currently, the number of bytes at the topic level is given by
backlogSize parameter. A similar parameter is required at each subscription
level.
Example:
./pulsar-admin topics partitioned-stats
persistent://public/default/sysresmetrics33
{
"averageMsgSize" : 0.0
"backlogSize" : 3500
"publishers" : [ ],
"subscriptions" : {
"0_itom_di_scheduler_provider_default_sysresmetrics33" : {
"msgBacklog" : 2,
"backlogSize" : 20
},
"2_itom_di_scheduler_provider_default_sysresmetrics33" : {
"msgBacklog" : 3,
"backlogSize" : 30
},
"1_itom_di_scheduler_provider_default_sysresmetrics33" : {
"msgBacklog" : 4,
"backlogSize" : 50
}
},
"replication" : { },
"metadata" : {
"partitions" : 3
},
"partitions" : { }
}
#### Steps to reproduce
Execute "./pulsar-admin topics partitioned-stats <topic_name> for any topic.
#### System configuration
**Pulsar version**: 2.6.1
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
