ConsumedTopicViewContent.Scala

@* * Copyright 2015 Yahoo Inc. Licensed under the Apache License, Version 2.0 * See accompanying LICENSE file. *@ @import kafka.manager.utils.LongFormatted @(cluster:String, consumer: String, topic: String, state: kafka.manager.model.ActorModel.ConsumedTopicState )(implicit messages: play.api.i18n.Messages, request:RequestHeader) @implicitFieldConstructor = @{ b4.vertical.fieldConstructor() } @getTopicCoverage(percentage: Int) = { @percentage match { case i if i <= 99 => {table-danger} case i => {} } } @ifPartitionNotOwned(owner: Option[String]) = { @owner match { case None => {table-warning} case Some(a) => {} } }

Topic Summary

| Total Lag | @state.totalLag.map(_.formattedAsDecimal).getOrElse(" ") | | % of Partitions assigned to a consumer instance | @state.percentageCovered |

@topic

Partition	LogSize	Consumer Offset	Lag	Consumer Instance Owner
@for(tp:Int <- 0 until state.numPartitions) {	@tp	@state.topicOffsets(tp).map(_.formattedAsDecimal).getOrElse(" ")	@state.partitionOffsets.get(tp).map(_.formattedAsDecimal).getOrElse(" ")	@state.partitionLag(tp).map(_.formattedAsDecimal).getOrElse(" ")
}