@* * 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)} } } @if(clusterContext.config.pollConsumers) { } @for( ((consumer, consumerType), consumerIdentityOpt) <- consumers) { @if(clusterContext.config.pollConsumers) { } }
Consumer TypeTopics it consumes from
@consumer @consumerType.toString @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)
} }