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