kafka

utils

package utils

Visibility
  1. Public
  2. All

Type Members

  1. class Crc32 extends Checksum

  2. class DelayedItem[T] extends Delayed with Logging

  3. class FileLock extends Logging

    A file lock a la flock/funlock

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

    Transliteration of the iterator template in google collections.

  5. class KafkaScheduler extends Scheduler with Logging

    A scheduler based on java.

  6. trait Logging extends AnyRef

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

  8. trait Scheduler extends AnyRef

    A scheduler for running jobs

  9. abstract class ShutdownableThread extends Thread with Logging

  10. class State extends AnyRef

  11. class Throttler extends Logging with KafkaMetricsGroup

    A class to measure and throttle the rate of some process.

  12. trait Time extends AnyRef

    A mockable interface for time functions

  13. class VerifiableProperties extends Logging

  14. class ZKConfig extends AnyRef

  15. class ZKGroupDirs extends AnyRef

  16. class ZKGroupTopicDirs extends ZKGroupDirs

  17. class immutable extends Annotation with StaticAnnotation

    Indicates that the annotated class is immutable

  18. class nonthreadsafe extends Annotation with StaticAnnotation

    Indicates that the annotated class is not threadsafe

  19. class threadsafe extends Annotation with StaticAnnotation

    Indicates that the annotated class is meant to be threadsafe.

Value Members

  1. object CommandLineUtils extends Logging

    Helper functions for dealing with command line utilities

  2. object DONE extends State

  3. object FAILED extends State

  4. object Json extends Logging

    A wrapper that synchronizes JSON in scala, which is not threadsafe.

  5. object Log4jController

  6. object Mx4jLoader extends Logging

    If mx4j-tools is in the classpath call maybeLoad to load the HTTP interface of mx4j.

  7. object NOT_READY extends State

  8. object Os

  9. object READY extends State

  10. object ReplicationUtils extends Logging

  11. object SystemTime extends Time

    The normal system implementation of time functions

  12. object Throttler

  13. object Time

    Some common constants

  14. object ToolsUtils

  15. object Utils extends Logging

    General helper functions!

  16. object ZKStringSerializer extends ZkSerializer

  17. object ZkUtils extends Logging

Ungrouped