@* * Copyright 2015 Yahoo Inc. Licensed under the Apache License, Version 2.0 * See accompanying LICENSE file. *@ @(cluster: String, brokerId: Int, brokerView :kafka.manager.model.ActorModel.BVView)(implicit af: features.ApplicationFeatures, messages: play.api.i18n.Messages, request:RequestHeader) @renderBrokerMetrics = { @if(brokerView.clusterContext.clusterFeatures.features(kafka.manager.features.KMJMXMetricsFeature)) { @views.html.common.brokerMetrics(brokerView.metrics) } else { } }

Summary

@if(brokerView.clusterContext.clusterFeatures.features(kafka.manager.features.KMJMXMetricsFeature)) { }
# of Topics@brokerView.numTopics
# of Partitions@brokerView.numPartitions
# of Partitions as Leader@brokerView.numPartitionsAsLeader
% of Messages@brokerView.stats.map(_.perMessages)
% of Incoming@brokerView.stats.map(_.perIncoming)
% of Outgoing@brokerView.stats.map(_.perOutgoing)
@if(!brokerView.broker.isEmpty && !brokerView.broker.get.config.isEmpty) { @for( (k,v) <- brokerView.broker.get.config) { }
ConfigValue
@k @v
}
@features.app(features.KMClusterManagerFeature) { }

Metrics

@renderBrokerMetrics

Messages count

Per Topic Detail

@for((ti,bp) <- brokerView.topicPartitions) { }
Topic Replication Total Partitions Partitions on Broker Partitions Skewed? # Partitions as Leader
@ti.topic @ti.replicationFactor @ti.partitions @bp.partitions.size @bp.partitions.mkString("(",",",")") @ti.partitionsByBroker.find(_.id == brokerId).map(_.isSkewed).getOrElse("Unknown") @bp.partitionsAsLeader.size