@* * Copyright 2015 Yahoo Inc. Licensed under the Apache License, Version 2.0 * See accompanying LICENSE file. *@ @import kafka.manager.utils.LongFormatted @(cluster: String, topics: IndexedSeq[((String, Option[kafka.manager.model.ActorModel.TopicIdentity]),Boolean)], topicsUnderReassignment: IndexedSeq[String], pollConsumers: Boolean, displayTopicSize: Boolean )(implicit messages: play.api.i18n.Messages, request:RequestHeader) @getDeletedLevel(deleted: Boolean) = { @deleted match { case true => {table-danger} case i => {} } } @getBrokersSpreadLevel(percentage: Int) = { @percentage match { case i if i > 50 && i <= 75 => {table-warning} case i if i <= 50 => {table-danger} case i => {} } } @getBrokersSkewLevel(percentage: Int) = { @percentage match { case i if i > 0 && i <= 33 => {table-warning} case i if i >= 34 => {table-danger} case i => {} } } @getBrokersLeaderSkewLevel(percentage: Int) = { @percentage match { case i if i > 0 && i <= 33 => {table-warning} case i if i >= 34 => {table-danger} case i => {} } } @getUnderReplicatedLevel(percentage: Int) = { @percentage match { case i if i > 0 && i <= 33 => {table-warning} case i if i >= 34 => {table-danger} case i => {} } } @getReassignmentStatus(topic: String) = { @if(topicsUnderReassignment.contains(topic)) {glow-red} else {} } @if(displayTopicSize){ } @if(pollConsumers){ } @for( ((topic, topicIdentity), deleted) <- topics) { @topicIdentity.map{ ti => }.getOrElse{} @topicIdentity.map{ ti => }.getOrElse{} @topicIdentity.map{ ti => }.getOrElse{} @topicIdentity.map{ ti => }.getOrElse{} @topicIdentity.map{ ti => }.getOrElse{} @topicIdentity.map{ ti => }.getOrElse{} @topicIdentity.map{ ti => }.getOrElse{} @if(displayTopicSize){ @topicIdentity.map{ ti => }.getOrElse{} } @if(pollConsumers){ @topicIdentity.map{ ti => }.getOrElse{} @topicIdentity.map{ ti => }.getOrElse{} } }
Topic # Partitions # Brokers Brokers Spread % Brokers Skew % Brokers Leader Skew % # Replicas Under Replicated %Leader SizeProducer Message/Sec Summed Recent Offsets
@topic@ti.partitions @ti.topicBrokers @ti.brokersSpreadPercentage @ti.brokersSkewPercentage @ti.brokersLeaderSkewPercentage @ti.replicationFactor @ti.underReplicatedPercentage @ti.size @ti.producerRate @ti.summedTopicOffsets.formattedAsDecimal