class Kafkat::ClusterRestart::Subcommands::Start

Attributes

session[R]

Public Instance Methods

run() click to toggle source
# File lib/kafkat/command/cluster_restart.rb, line 44
def run
  if Session.exists?
    puts "ERROR: A session is already started"
    puts "\n[Action] Please run 'next' or 'reset' commands"
    exit 1
  end

  print "Starting a new Cluster-Restart session.\n"

  @session = Session.from_zookeepers(zookeeper)
  @session.save!

  puts "\n[Action] Please run 'next' to select the broker with lowest restarting cost"
end