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