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. case class TestRecord(topic: String, key: Int, value: Long, delete: Boolean) extends Product with Serializable

  8. class ZooKeeperMainWrapper extends ZooKeeperMain

Value Members

  1. object ConsoleConsumer extends Logging

    Consumer that dumps messages out to standard out.

  2. object ConsoleProducer extends AnyRef

  3. object ConsumerOffsetChecker extends Logging

  4. object ConsumerPerformance extends AnyRef

    Performance test for the full zookeeper consumer

  5. object DumpLogSegments extends AnyRef

  6. 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:

  7. object GetOffsetShell extends AnyRef

  8. object ImportZkOffsets extends Logging

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

  9. object JmxTool extends Logging

  10. object KafkaMigrationTool extends

  11. object MirrorMaker extends Logging

  12. object ProducerPerformance extends Logging

    Load test for the producer

  13. object ReplayLogProducer extends Logging

  14. object ReplicaVerificationTool extends Logging

    For verifying the consistency among replicas.

  15. object SimpleConsumerPerformance extends AnyRef

    Performance test for the simple consumer

  16. object SimpleConsumerShell extends Logging

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

  17. object StateChangeLogMerger extends Logging

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

  18. object TestEndToEndLatency extends AnyRef

  19. object TestLogCleaning extends AnyRef

    This is a torture test that runs against an existing broker.

  20. object UpdateOffsetsInZK extends AnyRef

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

  21. object VerifyConsumerRebalance extends Logging

  22. object ZooKeeperMainWrapper extends AnyRef

    ZooKeeper 3.