Table of Contents - kafkat-0.3.0 Documentation
Classes and Modules
- Kafkat
- Kafkat::Assignment
- Kafkat::Broker
- Kafkat::CLI
- Kafkat::ClusterRestart
- Kafkat::ClusterRestart::ClusterRestartHelper
- Kafkat::ClusterRestart::Session
- Kafkat::ClusterRestart::Session::NotFoundError
- Kafkat::ClusterRestart::Session::ParseError
- Kafkat::ClusterRestart::Subcommands
- Kafkat::ClusterRestart::Subcommands::Good
- Kafkat::ClusterRestart::Subcommands::Help
- Kafkat::ClusterRestart::Subcommands::Log
- Kafkat::ClusterRestart::Subcommands::Next
- Kafkat::ClusterRestart::Subcommands::Reset
- Kafkat::ClusterRestart::Subcommands::Restore
- Kafkat::ClusterRestart::Subcommands::Start
- Kafkat::ClusterRestart::UnknownBrokerError
- Kafkat::ClusterRestart::UnknownStateError
- Kafkat::Command
- Kafkat::Command::Base
- Kafkat::Command::Brokers
- Kafkat::Command::CleanIndexes
- Kafkat::Command::ClusterRestart
- Kafkat::Command::Controller
- Kafkat::Command::Describe
- Kafkat::Command::Drain
- Kafkat::Command::ElectLeaders
- Kafkat::Command::NotFoundError
- Kafkat::Command::Reassign
- Kafkat::Command::Resign
- Kafkat::Command::ResignForce
- Kafkat::Command::SetReplicationFactor
- Kafkat::Command::Topics
- Kafkat::Command::VerifyReplicas
- Kafkat::CommandIO
- Kafkat::Config
- Kafkat::Config::NotFoundError
- Kafkat::Config::ParseError
- Kafkat::Formatting
- Kafkat::Interface
- Kafkat::Interface::Admin
- Kafkat::Interface::Admin::ExecutionFailedError
- Kafkat::Interface::KafkaLogs
- Kafkat::Interface::KafkaLogs::KafkaRunningError
- Kafkat::Interface::KafkaLogs::NoLogsError
- Kafkat::Interface::Zookeeper
- Kafkat::Interface::Zookeeper::NotFoundError
- Kafkat::Interface::Zookeeper::WriteConflictError
- Kafkat::Logging
- Kafkat::Partition
- Kafkat::Topic
Methods
- ::all — Kafkat::Command
- ::calculate_cost — Kafkat::ClusterRestart::ClusterRestartHelper
- ::exists? — Kafkat::ClusterRestart::Session
- ::from_brokers — Kafkat::ClusterRestart::Session
- ::from_zookeepers — Kafkat::ClusterRestart::Session
- ::get — Kafkat::Command
- ::get_broker_to_leader_partition_mapping — Kafkat::ClusterRestart::ClusterRestartHelper
- ::load! — Kafkat::ClusterRestart::Session
- ::load! — Kafkat::Config
- ::new — Kafkat::Command::Base
- ::new — Kafkat::ClusterRestart::Session
- ::new — Kafkat::Config
- ::new — Kafkat::Interface::Admin
- ::new — Kafkat::Interface::KafkaLogs
- ::new — Kafkat::Interface::Zookeeper
- ::register_as — Kafkat::Command::Base
- ::reset! — Kafkat::ClusterRestart::Session
- ::run! — Kafkat::CLI
- ::select_broker_with_min_cost — Kafkat::ClusterRestart::ClusterRestartHelper
- ::usage — Kafkat::Command::Base
- ::usages — Kafkat::Command::Base
- #admin — Kafkat::Command::Base
- #all_restarted? — Kafkat::ClusterRestart::Session
- #bad_config_error — Kafkat::CLI
- #broker_path — Kafkat::Interface::Zookeeper
- #brokers_path — Kafkat::Interface::Zookeeper
- #build_partitions_by_broker — Kafkat::Command::Drain
- #check_exists — Kafkat::Interface::KafkaLogs
- #clean_indexes! — Kafkat::Interface::KafkaLogs
- #controller_path — Kafkat::Interface::Zookeeper
- #elect_leaders! — Kafkat::Interface::Admin
- #generate_assignments — Kafkat::Command::Drain
- #get_broker — Kafkat::Interface::Zookeeper
- #get_broker_ids — Kafkat::Interface::Zookeeper
- #get_brokers — Kafkat::Interface::Zookeeper
- #get_controller — Kafkat::Interface::Zookeeper
- #get_topic — Kafkat::Interface::Zookeeper
- #get_topic_names — Kafkat::Interface::Zookeeper
- #get_topics — Kafkat::Interface::Zookeeper
- #has_leader? — Kafkat::Partition
- #increase_rf — Kafkat::Command::SetReplicationFactor
- #justify — Kafkat::Formatting
- #kafka_logs — Kafkat::Command::Base
- #load_config — Kafkat::CLI
- #lock_for_write — Kafkat::Interface::KafkaLogs
- #lockfile_path — Kafkat::Interface::KafkaLogs
- #no_command_error — Kafkat::CLI
- #no_config_error — Kafkat::CLI
- #not_restarted? — Kafkat::ClusterRestart::Session
- #only_unavailable? — Kafkat::Command::Describe
- #only_under_replicated? — Kafkat::Command::Describe
- #pending? — Kafkat::ClusterRestart::Session
- #pending_brokers — Kafkat::ClusterRestart::Session
- #pool — Kafkat::Interface::Zookeeper
- #print_assignment — Kafkat::Formatting
- #print_assignment_header — Kafkat::Formatting
- #print_banner — Kafkat::CLI
- #print_broker — Kafkat::Formatting
- #print_broker_header — Kafkat::Formatting
- #print_commands — Kafkat::CLI
- #print_err — Kafkat::Logging
- #print_mismatched_partitions — Kafkat::Command::VerifyReplicas
- #print_partition — Kafkat::Formatting
- #print_partition_header — Kafkat::Formatting
- #print_topic — Kafkat::Formatting
- #print_topic_header — Kafkat::Formatting
- #print_topic_name — Kafkat::Formatting
- #prompt_and_execute_assignments — Kafkat::CommandIO
- #reassign! — Kafkat::Interface::Admin
- #reduce_rf — Kafkat::Command::SetReplicationFactor
- #restart — Kafkat::ClusterRestart::Subcommands::Good
- #restarted? — Kafkat::ClusterRestart::Session
- #run — Kafkat::CLI
- #run — Kafkat::Command::Base
- #run — Kafkat::Command::Brokers
- #run — Kafkat::Command::CleanIndexes
- #run — Kafkat::Command::ClusterRestart
- #run — Kafkat::ClusterRestart::Subcommands::Help
- #run — Kafkat::ClusterRestart::Subcommands::Start
- #run — Kafkat::ClusterRestart::Subcommands::Reset
- #run — Kafkat::ClusterRestart::Subcommands::Restore
- #run — Kafkat::ClusterRestart::Subcommands::Next
- #run — Kafkat::ClusterRestart::Subcommands::Log
- #run — Kafkat::ClusterRestart::Subcommands::Good
- #run — Kafkat::Command::Controller
- #run — Kafkat::Command::Drain
- #run — Kafkat::Command::ElectLeaders
- #run — Kafkat::Command::Describe
- #run — Kafkat::Command::Reassign
- #run — Kafkat::Command::ResignForce
- #run — Kafkat::Command::SetReplicationFactor
- #run — Kafkat::Command::Resign
- #run — Kafkat::Command::Topics
- #run — Kafkat::Command::VerifyReplicas
- #run_command — Kafkat::CLI
- #run_tool — Kafkat::Interface::Admin
- #save! — Kafkat::ClusterRestart::Session
- #selected? — Kafkat::Command::Describe
- #shutdown! — Kafkat::Interface::Admin
- #state — Kafkat::ClusterRestart::Session
- #state? — Kafkat::ClusterRestart::Session
- #to_h — Kafkat::ClusterRestart::Session
- #topic_partition_state_path — Kafkat::Interface::Zookeeper
- #topic_partitions_path — Kafkat::Interface::Zookeeper
- #topic_path — Kafkat::Interface::Zookeeper
- #topics_path — Kafkat::Interface::Zookeeper
- #under_replicated? — Kafkat::Partition
- #update_states! — Kafkat::ClusterRestart::Session
- #verify_replicas — Kafkat::Command::VerifyReplicas
- #warn_reduce_brokers — Kafkat::Command::SetReplicationFactor
- #write_leader — Kafkat::Interface::Zookeeper
- #zk — Kafkat::Interface::Zookeeper
- #zookeeper — Kafkat::Command::Base