class YAKC::Configuration

Attributes

app[RW]
brokers[RW]
logger[RW]
suffix[RW]
topics[RW]
zookeepers[RW]

Public Class Methods

new() click to toggle source
# File lib/yakc/configuration.rb, line 5
def initialize
  @logger      = Logger.new(STDOUT)
  @brokers     = ENV.fetch("BROKERS", "localhost:9092").split(",")
  @zookeepers  = ENV.fetch("ZOOKEEPERS", "localhost:2181").split(",")
  @app         = ENV["APP"]
  @suffix      = ENV["SUFFIX"]
  @topics      = ENV.fetch("TOPICS", "").split(",")
end