@import kafka.manager.model.ActorModel.{TopicIdentity, BVView}
@(brokersViews: Seq[BVView])(implicit messages: play.api.i18n.Messages, request:RequestHeader)
Broker |
Messages in /sec |
Bytes in /sec |
Bytes out /sec |
@brokersViews.zipWithIndex.map { case (brokerView, idx) =>
@if(brokerView.clusterContext.clusterFeatures.features(kafka.manager.features.KMJMXMetricsFeature)) {
@idx |
@brokerView.metrics.map(_.messagesInPerSec.formatMeanRate)
|
@brokerView.metrics.map(_.bytesInPerSec.formatMeanRate)
|
@brokerView.metrics.map(_.bytesOutPerSec.formatMeanRate)
|
} else {
@idx |
NA
|
NA
|
NA
|
}
}
Broker |
Bytes rejected /sec |
Failed fetch request /sec |
Failed produce request /sec |
@brokersViews.zipWithIndex.map { case (brokerView, idx) =>
@if(brokerView.clusterContext.clusterFeatures.features(kafka.manager.features.KMJMXMetricsFeature)) {
@idx |
@brokerView.metrics.map(_.bytesRejectedPerSec.formatMeanRate)
|
@brokerView.metrics.map(_.failedFetchRequestsPerSec.formatMeanRate)
|
@brokerView.metrics.map(_.failedProduceRequestsPerSec.formatMeanRate)
|
} else {
@idx |
NA
|
NA
|
NA
|
}
}