Contents

module Kafka
  def self.load_jars(kafka_path = nil)
    kafka_path ||= ENV['KAFKA_PATH']

    raise 'Please set KAFKA_PATH' unless kafka_path
    dir = File.join(kafka_path, 'libs')
    jars = Dir.glob(File.join(dir, '*.jar'))
    raise "KAFKA_PATH set, but #{dir} contains no jar files." if jars.empty?
    jars.each { |jar| require jar }
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
jruby-kafka-0.2.1-java	lib/jruby-kafka/loader.rb
jruby-kafka-0.2.0-java	lib/jruby-kafka/loader.rb
jruby-kafka-0.1.3-java	lib/jruby-kafka/loader.rb
jruby-kafka-0.1.2-java	lib/jruby-kafka/loader.rb
jruby-kafka-0.1.1-java	lib/jruby-kafka/loader.rb