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