class Kafkat::Command::VerifyReassign

Public Instance Methods

run() click to toggle source
# File lib/kafkat/command/verify-reassign.rb, line 9
def run
  file_name = ARGV.shift

  all_brokers = zookeeper.get_brokers

  puts admin.verify_reassign(file_name)
end