class Kafkat::Command::Controller

Public Instance Methods

run() click to toggle source
# File lib/kafkat/command/controller.rb, line 9
def run
  c = zookeeper.get_controller
  print "The current controller is '#{c.id}' (#{c.host}:#{c.port}).\n"
rescue Interface::Zookeeper::NotFoundError
  print "ERROR: Couldn't determine the current controller.\n"
  exit 1
end