Produce returns a produce response or error
(request *ProduceRequest)
| 561 | |
| 562 | // Produce returns a produce response or error |
| 563 | func (b *Broker) Produce(request *ProduceRequest) (*ProduceResponse, error) { |
| 564 | var ( |
| 565 | response *ProduceResponse |
| 566 | err error |
| 567 | ) |
| 568 | |
| 569 | if request.RequiredAcks == NoResponse { |
| 570 | err = b.sendAndReceive(request, nil) |
| 571 | } else { |
| 572 | response = new(ProduceResponse) |
| 573 | err = b.sendAndReceive(request, response) |
| 574 | } |
| 575 | |
| 576 | if err != nil { |
| 577 | return nil, err |
| 578 | } |
| 579 | |
| 580 | return response, nil |
| 581 | } |
| 582 | |
| 583 | // Fetch returns a FetchResponse or error |
| 584 | func (b *Broker) Fetch(request *FetchRequest) (*FetchResponse, error) { |