@* * 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
@for(tp:Int <- 0 until state.numPartitions) { }
PartitionLogSizeConsumer OffsetLagConsumer Instance Owner
@tp @state.topicOffsets(tp).map(_.formattedAsDecimal).getOrElse(" ") @state.partitionOffsets.get(tp).map(_.formattedAsDecimal).getOrElse(" ") @state.partitionLag(tp).map(_.formattedAsDecimal).getOrElse(" ") @state.partitionOwners.get(tp).getOrElse("None")