class Kafkat::ClusterRestart::Subcommands::Reset

Public Instance Methods

run() click to toggle source
# File lib/kafkat/command/cluster_restart.rb, line 62
def run
  if Session.exists?
    Session.reset!
  end
  puts "Session reset"
  puts "\n[Action] Please run 'start' to start the session"
end