Rack returns the broker's rack as retrieved from Kafka's metadata or the empty string if it is not known. The returned value corresponds to the broker's broker.rack configuration setting. Requires protocol version to be at least v0.10.0.0.
()
| 438 | // broker's broker.rack configuration setting. Requires protocol version to be |
| 439 | // at least v0.10.0.0. |
| 440 | func (b *Broker) Rack() string { |
| 441 | if b.rack == nil { |
| 442 | return "" |
| 443 | } |
| 444 | return *b.rack |
| 445 | } |
| 446 | |
| 447 | // GetMetadata send a metadata request and returns a metadata response or error |
| 448 | func (b *Broker) GetMetadata(request *MetadataRequest) (*MetadataResponse, error) { |
no outgoing calls