MCPcopy
hub / github.com/IBM/sarama / Addr

Method Addr

broker.go:432–434  ·  view source on GitHub ↗

Addr returns the broker address as either retrieved from Kafka's metadata or passed to NewBroker.

()

Source from the content-addressed store, hash-verified

430
431// Addr returns the broker address as either retrieved from Kafka's metadata or passed to NewBroker.
432func (b *Broker) Addr() string {
433 return b.addr
434}
435
436// Rack returns the broker's rack as retrieved from Kafka's metadata or the
437// empty string if it is not known. The returned value corresponds to the

Calls

no outgoing calls