Class: Karafka::Cli::Server

Inherits:
Base
  • Object
show all
Includes:
Helpers::Colorize
Defined in:
lib/karafka/cli/server.rb

Overview

Server Karafka Cli action

Instance Attribute Summary

Attributes inherited from Base

#cli

Instance Method Summary collapse

Methods included from Helpers::Colorize

#green, #red

Methods inherited from Base

bind_to, desc, #initialize, option

Constructor Details

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

Instance Method Details

#call ⇒ Object

Start the Karafka server



17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/karafka/cli/server.rb', line 17

def call
  # Print our banner and info in the dev mode
  print_marketing_info if Karafka::App.env.development?

  active_routing_config = Karafka::App.config.internal.routing.active
  active_routing_config.consumer_groups = cli.options[:consumer_groups]
  active_routing_config.subscription_groups = cli.options[:subscription_groups]
  active_routing_config.topics = cli.options[:topics]

  Karafka::Server.run
end