kafka

tools

package tools

Visibility
  1. Public
  2. All

Type Members

  1. class ChecksumMessageFormatter extends MessageFormatter

  2. class DefaultMessageFormatter extends MessageFormatter

  3. class KafkaMigrationTool extends AnyRef

  4. trait MessageFormatter extends AnyRef

  5. class NoOpMessageFormatter extends MessageFormatter

  6. class PerfConfig extends AnyRef

  7. class ZooKeeperMainWrapper extends ZooKeeperMain

Value Members

  1. object ConsoleConsumer extends Logging

    Consumer that dumps messages to standard out.

  2. object ConsoleProducer

  3. object ConsumerOffsetChecker extends Logging

  4. object ConsumerPerformance

    Performance test for the full zookeeper consumer

  5. object DumpLogSegments

  6. object EndToEndLatency

    This class records the average end to end latency for a single message to travel through Kafka

  7. object ExportZkOffsets extends Logging

    A utility that retrieve the offset of broker partitions in ZK and prints to an output file in the following format:

  8. object GetOffsetShell

  9. object ImportZkOffsets extends Logging

    A utility that updates the offset of broker partitions in ZK.

  10. object JmxTool extends Logging

  11. object MirrorMaker extends Logging with KafkaMetricsGroup

    The mirror maker has the following architecture: - There are N mirror maker thread shares one ZookeeperConsumerConnector and each owns a Kafka stream.

  12. object ReplayLogProducer extends Logging

  13. object ReplicaVerificationTool extends Logging

    For verifying the consistency among replicas.

  14. object SimpleConsumerPerformance

    Performance test for the simple consumer

  15. object SimpleConsumerShell extends Logging

    Command line program to dump out messages to standard out using the simple consumer

  16. object StateChangeLogMerger extends Logging

    A utility that merges the state change logs (possibly obtained from different brokers and over multiple days).

  17. object UpdateOffsetsInZK

    A utility that updates the offset of every broker partition to the offset of earliest or latest log segment file, in ZK.

  18. object VerifyConsumerRebalance extends Logging

  19. object ZooKeeperMainWrapper

    ZooKeeper 3.

Deprecated Value Members

  1. object ProducerPerformance extends Logging

    Load test for the producer

Ungrouped