InitProducerID sends an init producer request and returns a response or error
(request *InitProducerIDRequest)
| 853 | |
| 854 | // InitProducerID sends an init producer request and returns a response or error |
| 855 | func (b *Broker) InitProducerID(request *InitProducerIDRequest) (*InitProducerIDResponse, error) { |
| 856 | response := new(InitProducerIDResponse) |
| 857 | response.Version = request.version() |
| 858 | |
| 859 | err := b.sendAndReceive(request, response) |
| 860 | if err != nil { |
| 861 | return nil, err |
| 862 | } |
| 863 | |
| 864 | return response, nil |
| 865 | } |
| 866 | |
| 867 | // AddPartitionsToTxn send a request to add partition to txn and returns |
| 868 | // a response or error |