Module: KafkaSyrup::Utils

Included in:
PartitionConsumer, Protocol::Base, Protocol::Message, Protocol::MessageSet, TopicConsumer, TopicProducer
Defined in:
lib/kafka_syrup/utils.rb

Instance Method Summary collapse

Instance Method Details

#load_args(*args) ⇒ Object 



3
4
5
6
7
8
9
 
# File 'lib/kafka_syrup/utils.rb', line 3

def load_args(*args)
  if args.last.is_a?(Hash)
    args.last.each do |attr, val|
      self.send("#{attr}=", val) if self.respond_to?("#{attr}=")
    end
  end
end

#log ⇒ Object 



11
12
13
 
# File 'lib/kafka_syrup/utils.rb', line 11

def log
  KafkaSyrup.config.logger
end