manager

case class ApiError(msg: String, recoverByForceOperation: Boolean = false) extends Product with Serializable
case class BrokerListExtended(list: IndexedSeq[BrokerIdentity], metrics: Map[Int, BrokerMetrics], combinedMetric: Option[BrokerMetrics], clusterContext: ClusterContext) extends Product with Serializable
case class ConsumerListExtended(list: IndexedSeq[((String, ConsumerType), Option[ConsumerIdentity])], clusterContext: ClusterContext) extends Product with Serializable
class KafkaManager extends Logging
case class LogkafkaListExtended(list: IndexedSeq[(String, Option[LogkafkaIdentity])], deleteSet: Set[String]) extends Product with Serializable
case class TopicListExtended(list: IndexedSeq[(String, Option[TopicIdentity])], topicToConsumerMap: Map[String, Iterable[(String, ConsumerType)]], deleteSet: Set[String], underReassignments: IndexedSeq[String], clusterContext: ClusterContext) extends Product with Serializable