class Kafkat::Config
Constants
- CONFIG_PATHS
Attributes
kafka_path[R]
log_path[R]
zk_path[R]
Public Class Methods
load!()
click to toggle source
# File lib/kafkat/config.rb, line 15 def self.load! string = nil e = nil CONFIG_PATHS.each do |rel_path| begin path = File.expand_path(rel_path) string = File.read(path) break rescue => e end end raise e if e && string.nil? json = JSON.parse(string) self.new(json) rescue Errno::ENOENT raise NotFoundError rescue JSON::JSONError raise ParseError end
new(json)
click to toggle source
# File lib/kafkat/config.rb, line 39 def initialize(json) @kafka_path = json['kafka_path'] @log_path = json['log_path'] @zk_path = json['zk_path'] end