@* * Copyright 2015 Yahoo Inc. Licensed under the Apache License, Version 2.0 * See accompanying LICENSE file. *@ @(cluster:String, consumer: String, consumerIdentity: kafka.manager.model.ActorModel.ConsumerIdentity)(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 => {} } }

Consumed Topic Information

@for((topic: String, state: kafka.manager.model.ActorModel.ConsumedTopicState) <- consumerIdentity.topicMap) { }
TopicPartitions Covered %Total Lag
@topic @state.percentageCovered @state.totalLag.getOrElse("not available")