Module: Kafka

Defined in:
lib/jruby-kafka.rb,
lib/jruby-kafka/loader.rb,
lib/jruby-kafka/namespace.rb

Defined Under Namespace

Classes: Consumer, Group, Producer

Class Method Summary collapse

Class Method Details

.load_jars(kafka_path = nil) ⇒ Object 



2
3
4
5
6
7
8
9
10
 
# File 'lib/jruby-kafka/loader.rb', line 2

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