Module: Ktl

Defined in:

lib/ktl.rb,
lib/ktl/cli.rb,
lib/ktl/topic.rb,
lib/ktl/cluster.rb,
lib/ktl/command.rb,
lib/ktl/version.rb,
lib/ktl/reassigner.rb,
lib/ktl/shuffle_plan.rb,
lib/ktl/migration_plan.rb,
lib/ktl/shell_formatter.rb,
lib/ktl/zookeeper_client.rb,
lib/ktl/decommission_plan.rb,
lib/ktl/reassignment_task.rb,
lib/ktl/cluster_stats_task.rb,
lib/ktl/reassignment_progress.rb

Defined Under Namespace

Modules: JavaConcurrent Classes: Cli, Cluster, ClusterStatsTask, Command, DecommissionPlan, MigrationPlan, NullLogger, RackAwareShufflePlan, Reassigner, ReassignmentProgress, ReassignmentTask, RendezvousShufflePlan, ShellFormater, ShufflePlan, Topic, ZookeeperClient

Constant Summary

KtlError =

Class.new(StandardError)

InsufficientBrokersRemainingError =

Class.new(KtlError)

CanBuildFrom =

Scala::Collection::Immutable::List.can_build_from

VERSION =

'1.0.0'.freeze