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