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

Reply via email to