Class: Sbmt::KafkaConsumer::CLI

Inherits:
Thor
  • Object
show all
Defined in:
lib/sbmt/kafka_consumer/cli.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.exit_on_failure? ⇒ Boolean

Returns:

  • (Boolean) 


6
7
8
 
# File 'lib/sbmt/kafka_consumer/cli.rb', line 6

def self.exit_on_failure?
  true
end

Instance Method Details

#start ⇒ Object 



22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/sbmt/kafka_consumer/cli.rb', line 22

def start
  $stdout.puts "Initializing KafkaConsumer"
  $stdout.puts "Version: #{VERSION}"

  load_environment

  $stdout.sync = true

  $stdout.puts "Configuring client"
  ClientConfigurer.configure!(
    consumer_groups: options[:consumer_group_id],
    concurrency: options[:concurrency]
  )
  $stdout.puts "Client configured routes: #{ClientConfigurer.routes.inspect}"

  $stdout.puts "Starting probes/metrics http-server"
  Sbmt::KafkaConsumer::Probes::Host.run_async

  Sbmt::KafkaConsumer::Server.run
end