utils

Type Members

class Crc32 extends Checksum
class DelayedItem[T] extends Delayed with Logging
class FileLock extends Logging

A file lock a la flock/funlock
A file lock a la flock/funlock
The given path will be created and opened if it doesn't exist.
abstract class IteratorTemplate[T] extends Iterator[T] with Iterator[T]

Transliteration of the iterator template in google collections.
Transliteration of the iterator template in google collections. To implement an iterator override makeNext and call allDone() when there is no more items
class KafkaScheduler extends Scheduler with Logging

A scheduler based on java.
A scheduler based on java.util.concurrent.ScheduledThreadPoolExecutor
It has a pool of kafka-scheduler- threads that do the actual work.

Annotations
@threadsafe()
trait Logging extends AnyRef
class Pool[K, V] extends Iterable[(K, V)]
trait Scheduler extends AnyRef

A scheduler for running jobs
A scheduler for running jobs
This interface controls a job scheduler that allows scheduling either repeating background jobs that execute periodically or delayed one-time actions that are scheduled in the future.
abstract class ShutdownableThread extends Thread with Logging
class State extends AnyRef
class Throttler extends Logging with KafkaMetricsGroup

A class to measure and throttle the rate of some process.
A class to measure and throttle the rate of some process. The throttler takes a desired rate-per-second (the units of the process don't matter, it could be bytes or a count of some other thing), and will sleep for an appropriate amount of time when maybeThrottle() is called to attain the desired rate.

Annotations
@threadsafe()
trait Time extends AnyRef

A mockable interface for time functions
class VerifiableProperties extends Logging
class ZKConfig extends AnyRef
class ZKGroupDirs extends AnyRef
class ZKGroupTopicDirs extends ZKGroupDirs
class immutable extends Annotation with StaticAnnotation

Indicates that the annotated class is immutable
class nonthreadsafe extends Annotation with StaticAnnotation

Indicates that the annotated class is not threadsafe
class threadsafe extends Annotation with StaticAnnotation

Indicates that the annotated class is meant to be threadsafe.
Indicates that the annotated class is meant to be threadsafe. For an abstract class it is an part of the interface that an implementation must respect

Value Members

object CommandLineUtils extends Logging

Helper functions for dealing with command line utilities
object DONE extends State
object FAILED extends State
object Json extends Logging

A wrapper that synchronizes JSON in scala, which is not threadsafe.
object Log4jController
object Mx4jLoader extends Logging

If mx4j-tools is in the classpath call maybeLoad to load the HTTP interface of mx4j.
If mx4j-tools is in the classpath call maybeLoad to load the HTTP interface of mx4j.
The default port is 8082. To override that provide e.g. -Dmx4jport=8083 The default listen address is 0.0.0.0. To override that provide -Dmx4jaddress=127.0.0.1 This feature must be enabled with -Dmx4jenable=true
This is a Scala port of org.apache.cassandra.utils.Mx4jTool written by Ran Tavory for CASSANDRA-1068
object NOT_READY extends State
object Os
object READY extends State
object ReplicationUtils extends Logging
object SystemTime extends Time

The normal system implementation of time functions
object Throttler
object Time

Some common constants
object ToolsUtils
object Utils extends Logging

General helper functions!
General helper functions!
This is for general helper functions that aren't specific to Kafka logic. Things that should have been included in the standard library etc.
If you are making a new helper function and want to add it to this class please ensure the following: 1. It has documentation 2. It is the most general possible utility, not just the thing you needed in one particular place 3. You have tests for it if it is nontrivial in any way
object ZKStringSerializer extends ZkSerializer
object ZkUtils extends Logging

package utils

Type Members

class Crc32 extends Checksum

class DelayedItem[T] extends Delayed with Logging

class FileLock extends Logging

abstract class IteratorTemplate[T] extends Iterator[T] with Iterator[T]

class KafkaScheduler extends Scheduler with Logging

trait Logging extends AnyRef

class Pool[K, V] extends Iterable[(K, V)]

trait Scheduler extends AnyRef

abstract class ShutdownableThread extends Thread with Logging

class State extends AnyRef

class Throttler extends Logging with KafkaMetricsGroup

trait Time extends AnyRef

class VerifiableProperties extends Logging

class ZKConfig extends AnyRef

class ZKGroupDirs extends AnyRef

class ZKGroupTopicDirs extends ZKGroupDirs

class immutable extends Annotation with StaticAnnotation

class nonthreadsafe extends Annotation with StaticAnnotation

class threadsafe extends Annotation with StaticAnnotation

Value Members

object CommandLineUtils extends Logging

object DONE extends State

object FAILED extends State

object Json extends Logging

object Log4jController

object Mx4jLoader extends Logging

object NOT_READY extends State

object Os

object READY extends State

object ReplicationUtils extends Logging

object SystemTime extends Time

object Throttler

object Time

object ToolsUtils

object Utils extends Logging

object ZKStringSerializer extends ZkSerializer

object ZkUtils extends Logging

Ungrouped