AddPartitionsToTxn send a request to add partition to txn and returns a response or error
(request *AddPartitionsToTxnRequest)
| 867 | // AddPartitionsToTxn send a request to add partition to txn and returns |
| 868 | // a response or error |
| 869 | func (b *Broker) AddPartitionsToTxn(request *AddPartitionsToTxnRequest) (*AddPartitionsToTxnResponse, error) { |
| 870 | response := new(AddPartitionsToTxnResponse) |
| 871 | |
| 872 | err := b.sendAndReceive(request, response) |
| 873 | if err != nil { |
| 874 | return nil, err |
| 875 | } |
| 876 | |
| 877 | return response, nil |
| 878 | } |
| 879 | |
| 880 | // AddOffsetsToTxn sends a request to add offsets to txn and returns a response |
| 881 | // or error |