Class: Kafka::Utility

Inherits:
Object
  • Object
show all
Defined in:
lib/jruby-kafka/utility.rb

Class Method Summary collapse

Class Method Details

.java_properties(properties) ⇒ Object 



5
6
7
8
9
10
11
12
13
 
# File 'lib/jruby-kafka/utility.rb', line 5

def self.java_properties(properties)
  java_properties = java.util.Properties.new
  properties.each do |k,v|
    k = k.to_s.gsub '_', '.'
    v = v.to_s
    java_properties.setProperty k, v
  end
  java_properties
end

.validate_arguments(required_options, options) ⇒ Object 



15
16
17
18
19
 
# File 'lib/jruby-kafka/utility.rb', line 15

def self.validate_arguments(required_options, options)
  required_options.each do |opt|
    raise ArgumentError, "Parameter :#{opt} is required." unless options[opt]
  end
end