Method List

Classes Methods Files

Search:

#add_partition_to_all_lowest Kafkat::Command::Reassign
#add_partition_to_node Kafkat::Command::Reassign
#admin Kafkat::Command::Base
all Kafkat::Command
#all_restarted? Kafkat::ClusterRestart::Session
#bad_config_error Kafkat::CLI
#broker_states Kafkat::ClusterRestart::Session
#build_partitions_by_broker Kafkat::Command::Drain
calculate_cost Kafkat::ClusterRestart::ClusterRestartHelper
#clean_indexes! Kafkat::Interface::KafkaLogs
command_name Kafkat::Command::Base
#config Kafkat::Command::Base
#config Kafkat::CLI
#elect_leaders! Kafkat::Interface::Admin
exists? Kafkat::ClusterRestart::Session
from_brokers Kafkat::ClusterRestart::Session
from_zookeepers Kafkat::ClusterRestart::Session
#generate_assignments Kafkat::Command::Drain
get Kafkat::Command
#get_broker Kafkat::Interface::Zookeeper
#get_broker_ids Kafkat::Interface::Zookeeper
get_broker_to_leader_partition_mapping Kafkat::ClusterRestart::ClusterRestartHelper
#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
#hmap Hash
#hmap! Hash
#host Kafkat::Broker
#id Kafkat::Broker
#id Kafkat::Partition
#increase_rf Kafkat::Command::SetReplicationFactor
#initialize Kafkat::Command::Base
#initialize Kafkat::Config
#initialize Kafkat::Interface::KafkaLogs
#initialize Kafkat::Interface::Zookeeper
#initialize Kafkat::ClusterRestart::Session
#initialize Kafkat::Interface::Admin
#isr Kafkat::Partition
#json_files_path Kafkat::Interface::Admin
#json_files_path Kafkat::Config
#justify Kafkat::Formatting
#kafka_logs Kafkat::Command::Base
#kafka_path Kafkat::Interface::Admin
#kafka_path Kafkat::Config
#leader Kafkat::Partition
load! Kafkat::Config
load! Kafkat::ClusterRestart::Session
#load_config Kafkat::CLI
#log_path Kafkat::Config
#log_path Kafkat::Interface::KafkaLogs
#migrate_excess_replicas_from_node Kafkat::Command::Reassign
#name Kafkat::Topic
#no_command_error Kafkat::CLI
#no_config_error Kafkat::CLI
#not_restarted? Kafkat::ClusterRestart::Session
#partition_id Kafkat::Assignment
#partitions Kafkat::Topic
#pending? Kafkat::ClusterRestart::Session
#pending_brokers Kafkat::ClusterRestart::Session
#port Kafkat::Broker
#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
register_as Kafkat::Command::Base
#remove_excess_replicas_from_node Kafkat::Command::Reassign
#remove_partition_from_node Kafkat::Command::Reassign
#replicas Kafkat::Partition
#replicas Kafkat::Assignment
reset! Kafkat::ClusterRestart::Session
#restart Kafkat::ClusterRestart::Subcommands::Good
#restarted? Kafkat::ClusterRestart::Session
#run Kafkat::Command::VerifyReplicas
#run Kafkat::Command::Resign
#run Kafkat::Command::Reassign
#run Kafkat::Command::Brokers
#run Kafkat::Command::Topics
#run Kafkat::Command::Drain
#run Kafkat::ClusterRestart::Subcommands::Log
#run Kafkat::Command::Describe
#run Kafkat::Command::Controller
#run Kafkat::Command::ResignForce
#run Kafkat::ClusterRestart::Subcommands::Help
#run Kafkat::ClusterRestart::Subcommands::Start
#run Kafkat::ClusterRestart::Subcommands::Reset
#run Kafkat::Command::CleanIndexes
#run Kafkat::Command::ElectLeaders
#run Kafkat::Command::ClusterRestart
#run Kafkat::ClusterRestart::Subcommands::Restore
#run Kafkat::ClusterRestart::Subcommands::Next
#run Kafkat::Command::VerifyReassign
#run Kafkat::ClusterRestart::Subcommands::Good
#run Kafkat::Command::SetReplicationFactor
#run Kafkat::CLI
#run Kafkat::Command::Base
run! Kafkat::CLI
#run_command Kafkat::CLI
#run_tool Kafkat::Interface::Admin
#save! Kafkat::ClusterRestart::Session
select_broker_with_min_cost Kafkat::ClusterRestart::ClusterRestartHelper
#session Kafkat::ClusterRestart::Subcommands::Restore
#session Kafkat::ClusterRestart::Subcommands::Next
#session Kafkat::ClusterRestart::Subcommands::Log
#session Kafkat::ClusterRestart::Subcommands::Start
#session Kafkat::ClusterRestart::Subcommands::Good
#shutdown! Kafkat::Interface::Admin
#state Kafkat::ClusterRestart::Session
#state? Kafkat::ClusterRestart::Session
#to_h Kafkat::ClusterRestart::Session
#topic_name Kafkat::Assignment
#topic_name Kafkat::Partition
#topics Kafkat::ClusterRestart::Subcommands::Next
#under_replicated? Kafkat::Partition
#update_states! Kafkat::ClusterRestart::Session
usage Kafkat::Command::Base
usages Kafkat::Command::Base
#verify_reassign Kafkat::Interface::Admin
#verify_replicas Kafkat::Command::VerifyReplicas
#warn_reduce_brokers Kafkat::Command::SetReplicationFactor
#write_leader Kafkat::Interface::Zookeeper
#zk_path Kafkat::Interface::Zookeeper
#zk_path Kafkat::Interface::Admin
#zk_path Kafkat::Config
#zookeeper Kafkat::Command::Base