Class: Karafka::Cli::Topics

Inherits:
Base
  • Object
show all
Includes:
Helpers::Colorize
Defined in:
lib/karafka/cli/topics.rb,
lib/karafka/cli/topics/base.rb,
lib/karafka/cli/topics/help.rb,
lib/karafka/cli/topics/plan.rb,
lib/karafka/cli/topics/align.rb,
lib/karafka/cli/topics/reset.rb,
lib/karafka/cli/topics/create.rb,
lib/karafka/cli/topics/delete.rb,
lib/karafka/cli/topics/migrate.rb,
lib/karafka/cli/topics/repartition.rb

Overview

CLI actions related to Kafka cluster topics management

Defined Under Namespace

Classes: Align, Base, Create, Delete, Help, Migrate, Plan, Repartition, Reset

Instance Attribute Summary

Attributes inherited from Base

#options

Instance Method Summary collapse

Methods included from Helpers::Colorize

#green, #grey, #red, #yellow

Methods inherited from Base

aliases, commands, desc, #initialize, load, name, names, option, parse_options

Constructor Details

This class inherits a constructor from Karafka::Cli::Base

Instance Method Details

#call(action = 'help') ⇒ Object

Parameters:

  • action (String) (defaults to: 'help') —

    action we want to take



36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/karafka/cli/topics.rb', line 36

def call(action = 'help')
  detailed_exit_code = options.fetch(:detailed_exitcode, false)

  command = case action
            when 'create'
              Topics::Create
            when 'delete'
              Topics::Delete
            when 'reset'
              Topics::Reset
            when 'repartition'
              Topics::Repartition
            when 'migrate'
              Topics::Migrate
            when 'align'
              Topics::Align
            when 'plan'
              Topics::Plan
            when 'help'
              Topics::Help
            else
              raise Errors::UnrecognizedCommandError, "Unrecognized topics action: #{action}"
            end

  changes = command.new.call

  return unless detailed_exit_code

  changes ? exit(CHANGES_EXIT_CODE) : exit(NO_CHANGES_EXIT_CODE)
rescue Errors::CommandValidationError
  exit(ERROR_EXIT_CODE)
end