Method: Kafka::MultiProducer#initialize

Defined in:
lib/kafka/multi_producer.rb

#initialize(options = {}) ⇒ MultiProducer

Returns a new instance of MultiProducer.



19
20
21
22
23
24
 
# File 'lib/kafka/multi_producer.rb', line 19

def initialize(options={})
  self.host = options[:host] || HOST
  self.port = options[:port] || PORT
  self.compression = options[:compression] || Message::NO_COMPRESSION
  self.connect(self.host, self.port)
end