class Anschel::Input::Kafka

Public Class Methods

new(output, config, stats, log) click to toggle source
# 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

Public Instance Methods

stop() click to toggle source
# File lib/anschel/input/kafka.rb, line 14
def stop
  return if @stopped
  @consumer_group.shutdown
  @stopped = true
end