Contents

require 'jruby-kafka'

require_relative 'base'


module Anschel
  class Input
    class Kafka < Base
      def initialize queue, config, stats, log
        @consumer_group = ::Kafka::Group.new config
        @consumer_group.run num_cpus, queue
      end

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

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
anschel-0.6.4	lib/anschel/input/kafka.rb
anschel-0.6.3	lib/anschel/input/kafka.rb
anschel-0.6.2	lib/anschel/input/kafka.rb