Back to Cmak

ShortBrokerMetrics.Scala

app/views/common/shortBrokerMetrics.scala.html

3.0.0.61.1 KB
Original Source

@import kafka.manager.model.ActorModel.{TopicIdentity, BVView} @(brokersViews: Seq[BVView])(implicit messages: play.api.i18n.Messages, request:RequestHeader)

BrokerMessages in /secBytes in /secBytes 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)
} else {@idxNANA
} }
BrokerBytes rejected /secFailed fetch request /secFailed 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)
} else {@idxNANA
} }