BrokerViewContent.Scala - Cmak

@* * 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 {

Please enable JMX polling here. } }

Summary

| # of Topics | @brokerView.numTopics | | # of Partitions | @brokerView.numPartitions | | # of Partitions as Leader | @brokerView.numPartitionsAsLeader | @if(brokerView.clusterContext.clusterFeatures.features(kafka.manager.features.KMJMXMetricsFeature)) { | % 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) {

Config | Value | @for( (k,v) <- brokerView.broker.get.config) { | @k | @v | } }

@features.app(features.KMClusterManagerFeature) {

Operations

update broker config

}

Metrics

@renderBrokerMetrics

Messages count

Per Topic Detail

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