@* * Copyright 2015 Yahoo Inc. Licensed under the Apache License, Version 2.0 * See accompanying LICENSE file. *@ @import kafka.manager.model.ActorModel.ConsumerType @import kafka.manager.model.ActorModel.ConsumerIdentity @import kafka.manager.model.ClusterContext @(cluster: String, consumers: IndexedSeq[((String, ConsumerType), Option[ConsumerIdentity])], clusterContext: ClusterContext)(implicit messages: play.api.i18n.Messages, request:RequestHeader) @getConsumedTopicSummary(state: kafka.manager.model.ActorModel.ConsumedTopicState) = { @state.percentageCovered match { case i if i <= 99 => { (@state.percentageCovered% coverage, @state.totalLag.getOrElse("Lag unavailable") lag) } case i => {(@state.percentageCovered% coverage, @state.totalLag.getOrElse("Lag unavailable") lag)} } }
Consumer | Type | @if(clusterContext.config.pollConsumers) {Topics it consumes from | }
---|---|---|
@consumer | @consumerType.toString | @if(clusterContext.config.pollConsumers) {
@consumerIdentityOpt.fold{
No details available for this consumer at this time
}{ a:kafka.manager.model.ActorModel.ConsumerIdentity =>
@for((topic: String, state: kafka.manager.model.ActorModel.ConsumedTopicState) <- a.topicMap) {
@topic:
@getConsumedTopicSummary(state) } } |
}