Sha256: da6bda512d5ffc352ae89f896d3b28ff1d99831351fdb1c8e4a91128a8876489
Contents?: true
Size: 383 Bytes
Versions: 21
Compression:
Stored size: 383 Bytes
Contents
require 'jruby-kafka'
require_relative 'base'
module Anschel
class Input
class Kafka < Base
def initialize output, config, stats, log
@consumer_group = ::Kafka::Group.new config
@consumer_group.run num_cpus, output
end
def stop
return if @stopped
@consumer_group.shutdown
@stopped = true
end
end
end
end
Version data entries
21 entries across 21 versions & 1 rubygems