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