The Metrics ReplicationBytesInPerSec does not have label of topic

[Wong Lucent <ma...@live.cn>]

Hi,


I found that the metcis kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec only exposes on allTopicsStates, so that it cannot expose the metrics in Topic level.

brokerTopicStats.updateReplicationBytesIn(records.sizeInBytes)

def updateReplicationBytesIn(value: Long): Unit = {
  allTopicsStats.replicationBytesInRate.foreach { metric =>
    metric.mark(value)
  }
}

May I ask if there is any concern to expose this kind of metrics for every topic? Because it seems there exists stats for every topic in the class BrokerTopicStats.



Thanks and Best Regards
Lucent Wong