EndTxn sends a request to end txn and returns a response or error
(request *EndTxnRequest)
| 892 | |
| 893 | // EndTxn sends a request to end txn and returns a response or error |
| 894 | func (b *Broker) EndTxn(request *EndTxnRequest) (*EndTxnResponse, error) { |
| 895 | response := new(EndTxnResponse) |
| 896 | |
| 897 | err := b.sendAndReceive(request, response) |
| 898 | if err != nil { |
| 899 | return nil, err |
| 900 | } |
| 901 | |
| 902 | return response, nil |
| 903 | } |
| 904 | |
| 905 | // TxnOffsetCommit sends a request to commit transaction offsets and returns |
| 906 | // a response or error |