@*
* 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) => {}
}
}
Total Lag |
@state.totalLag.map(_.formattedAsDecimal).getOrElse(" ") |
% of Partitions assigned to a consumer instance |
@state.percentageCovered |
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(" ") |
@state.partitionOwners.get(tp).getOrElse("None") |
}