ApiVersions return api version response or error
(request *ApiVersionsRequest)
| 706 | |
| 707 | // ApiVersions return api version response or error |
| 708 | func (b *Broker) ApiVersions(request *ApiVersionsRequest) (*ApiVersionsResponse, error) { |
| 709 | response := new(ApiVersionsResponse) |
| 710 | |
| 711 | err := b.sendAndReceive(request, response) |
| 712 | if err != nil { |
| 713 | return nil, err |
| 714 | } |
| 715 | |
| 716 | return response, nil |
| 717 | } |
| 718 | |
| 719 | // CreateTopics send a create topic request and returns create topic response |
| 720 | func (b *Broker) CreateTopics(request *CreateTopicsRequest) (*CreateTopicsResponse, error) { |