class Kazoo::CLI::Cluster
Public Instance Methods
brokers()
click to toggle source
# File lib/kazoo/cli/cluster.rb, line 7 def brokers validate_class_options! kafka_cluster.brokers.values.sort_by(&:id).each do |broker| $stdout.puts "#{broker.id}:\t#{broker.addr}\t(hosts #{broker.replicated_partitions.length} partitions, leads #{broker.led_partitions.length})" end end
critical(broker_name)
click to toggle source
# File lib/kazoo/cli/cluster.rb, line 17 def critical(broker_name) validate_class_options! if broker(broker_name).critical?(replicas: options[:replicas]) raise Thor::Error, "WARNING: broker #{broker_name} is critical and cannot be stopped safely!" else $stdout.puts "Broker #{broker_name} is non-critical and can be stopped safely." end end
election()
click to toggle source
# File lib/kazoo/cli/cluster.rb, line 28 def election validate_class_options! kafka_cluster.preferred_leader_election end