< Back
 

# Packages

-  package root
  Definition Classes
    root
-  package kafka
  Definition Classes
    root
-  package manager

  Definition Classes
    kafka
-  package actor
-  package base
-  package features
-  package jmx
-  package logkafka
-  package model
-  package utils

- ApiError
- BrokerListExtended
- ConsumerListExtended
- KafkaManager
- LogkafkaListExtended
- TopicListExtended

p

kafka

# manager 

#### package manager

Linear Supertypes
AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. manager
2. AnyRef
3. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Type Members

1.  case class ApiError(msg: String, recoverByForceOperation: Boolean = false) extends Product with Serializable
2.  case class BrokerListExtended(list: IndexedSeq[BrokerIdentity], metrics: Map[Int, BrokerMetrics], combinedMetric: Option[BrokerMetrics], clusterContext: ClusterContext) extends Product with Serializable
3.  case class ConsumerListExtended(list: IndexedSeq[((String, ConsumerType), Option[ConsumerIdentity])], clusterContext: ClusterContext) extends Product with Serializable
4.  class KafkaManager extends Logging
5.  case class LogkafkaListExtended(list: IndexedSeq[(String, Option[LogkafkaIdentity])], deleteSet: Set[String]) extends Product with Serializable
6.  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

### Value Members

1.  def asByteArray(str: String): Array[Byte]
2.  def asString(ba: Array[Byte]): String
3.  def nodeFromPath(s: String): String
4.  object ApiError extends Logging with Serializable
5.  object KafkaManager

### Inherited from AnyRef

### Inherited from Any

### Ungrouped