Method: Kafka::MultiProducer#multi_push

Defined in:: lib/kafka/multi_producer.rb

#multi_push(producer_requests) ⇒ `Object`



31
32
33

# File 'lib/kafka/multi_producer.rb', line 31

def multi_push(producer_requests)
  self.write(Encoder.multiproduce(producer_requests, compression))
end