GetConsumerMetadata send a consumer metadata request and returns a consumer metadata response or error
(request *ConsumerMetadataRequest)
| 470 | |
| 471 | // GetConsumerMetadata send a consumer metadata request and returns a consumer metadata response or error |
| 472 | func (b *Broker) GetConsumerMetadata(request *ConsumerMetadataRequest) (*ConsumerMetadataResponse, error) { |
| 473 | response := new(ConsumerMetadataResponse) |
| 474 | |
| 475 | err := b.sendAndReceive(request, response) |
| 476 | if err != nil { |
| 477 | return nil, err |
| 478 | } |
| 479 | |
| 480 | return response, nil |
| 481 | } |
| 482 | |
| 483 | // FindCoordinator sends a find coordinate request and returns a response or error |
| 484 | func (b *Broker) FindCoordinator(request *FindCoordinatorRequest) (*FindCoordinatorResponse, error) { |
no test coverage detected