module Kafkat::CommandIO

Public Instance Methods

prompt_and_execute_assignments(assignments) click to toggle source
# File lib/kafkat/utility/command_io.rb, line 3
def prompt_and_execute_assignments(assignments)
  print "This operation executes the following assignments:\n\n"
  print_assignment_header
  assignments.each { |a| print_assignment(a) }
  print "\n"

  return unless agree("Proceed (y/n)?")

  result = nil
  begin
    print "\nBeginning.\n"
    result = admin.reassign!(assignments)
    print "Started.\n"
  rescue Interface::Admin::ExecutionFailedError
    print result
  end
end