Module: KafkaRest::Producable

Included in:
Partition
Defined in:
lib/kafka_rest/producable.rb

Instance Method Summary collapse

Instance Method Details

#produce(*messages) ⇒ Object 



3
4
5
 
# File 'lib/kafka_rest/producable.rb', line 3

def produce(*messages)
  client.post(produce_path, records: messages.flatten.map(&wrap))
end