< Back
 

# Packages

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

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

  Definition Classes
    manager
-  package logkafka81
-  package logkafka82
-  package one10
-  package two00
-  package zero10
-  package zero11
-  package zero81
-  package zero82
-  package zero90
- AdminUtils
- FiniteQueue
- Logkafka
- LogkafkaAdminUtils
- LogkafkaErrors
- LogkafkaNewConfigs
- LogkafkaZkUtils
- LongFormatted
- Topic
- TopicConfigs
- TopicErrors
- UtilError
- UtilException
- ZkUtils
- repeatWithIndex

p

kafka.manager

# utils 

#### package utils

Linear Supertypes
AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. utils
2. AnyRef
3. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Type Members

1.  class AdminUtils extends Logging

   Borrowed from kafka 0.8.1.1, adapted to use curator framework https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/admin/AdminUtils.scala

2.  class FiniteQueue[A] extends AnyRef
3.  class LogkafkaAdminUtils extends Logging
4.  trait LogkafkaNewConfigs extends AnyRef
5.  implicit class LongFormatted extends AnyRef
6.  trait TopicConfigs extends AnyRef
7.  abstract class UtilError extends AnyRef

8.  case class UtilException(error: UtilError) extends IllegalArgumentException with Product with Serializable

### Value Members

1.  def checkCondition(cond: Boolean, error: UtilError): Unit
   Annotations
     @throws( ... )
2.  implicit def deserializeString(data: Array[Byte]): String
3.  implicit val formats: DefaultFormats.type
4.  def fromJson[T](s: String): T
5.  def parseJson(s: String): JValue
6.  implicit def serializeString(data: String): Array[Byte]
7.  def throwError[T](error: UtilError): T
   Annotations
     @throws( ... )
8.  def toJson(s: String): String
9.  def toJson(map: Map[String, Any]): String
10.  object Logkafka extends Logging

    Borrowed from kafka 0.8.1.1 https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/common/Logkafka.scala

11.  object LogkafkaErrors
12.  object LogkafkaNewConfigs
13.  object LogkafkaZkUtils
14.  object Topic

    Borrowed from kafka 0.8.1.1 https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/common/Topic.scala

15.  object TopicConfigs
16.  object TopicErrors
17.  object ZkUtils

    Borrowed from kafka 0.8.1.1.

    Borrowed from kafka 0.8.1.1. Adapted to use curator framework. https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/utils/ZkUtils.scala

18.  object repeatWithIndex

### Inherited from AnyRef

### Inherited from Any

### Ungrouped