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