Class: Anschel::Input::Kafka

Inherits:

Base

• Object
• Base
• Anschel::Input::Kafka

Defined in:

lib/anschel/input/kafka.rb

Instance Method Summary

• #initialize(output, config, stats, log) ⇒ Kafka constructor

  A new instance of Kafka.

• #stop ⇒ Object

Constructor Details

#initialize(output, config, stats, log) ⇒ Kafka

Returns a new instance of Kafka.

# File 'lib/anschel/input/kafka.rb', line 9

def initialize output, config, stats, log
  @consumer_group = ::Kafka::Group.new config
  @consumer_group.run num_cpus, output
end

Instance Method Details

#stop ⇒ Object

# File 'lib/anschel/input/kafka.rb', line 14

def stop
  return if @stopped
  @consumer_group.shutdown
  @stopped = true
end