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

  3. object ConsumerOffsetChecker extends Logging

  4. object ConsumerPerformance

    Performance test for the full zookeeper consumer

  5. object DumpLogSegments

  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

  8. object ImportZkOffsets extends Logging

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

  9. object JmxTool extends Logging

  10. object MirrorMaker extends Logging

  11. object ProducerPerformance extends Logging

    Load test for the producer

  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 TestEndToEndLatency

  18. object TestLogCleaning

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

  19. object UpdateOffsetsInZK

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

  20. object VerifyConsumerRebalance extends Logging

  21. object ZooKeeperMainWrapper

    ZooKeeper 3.

Ungrouped