Method AddBatch

produce_request.go:313–316

(topic string, partition int32, batch *RecordBatch)

}

func (r *ProduceRequest) AddBatch(topic string, partition int32, batch *RecordBatch) {
	r.ensureRecords(topic, partition)
	r.records[topic][partition] = newDefaultRecords(batch)
}