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