class Karafka::Cli::Worker

Worker Karafka Cli action

Public Instance Methods

call(*params) click to toggle source

Start the Karafka Sidekiq worker @param params [Array<String>] additional params that will be passed to sidekiq, that way we

can override any default Karafka settings
# File lib/karafka/cli/worker.rb, line 14
def call(*params)
  puts 'Starting Karafka worker'
  config = "-C #{Karafka::App.root.join('config/sidekiq.yml')}"
  req = "-r #{Karafka.boot_file}"
  env = "-e #{Karafka.env}"

  cli.info

  cmd = "bundle exec sidekiq #{env} #{req} #{config} #{params.join(' ')}"
  puts(cmd)
  exec(cmd)
end