class Kafkat::Command::Brokers

Public Instance Methods

run() click to toggle source
# File lib/kafkat/command/brokers.rb, line 9
def run
  bs = zookeeper.get_brokers
  print_broker_header
  bs.each { |id, b| print_broker(b) }
end