|
@@ -102,7 +102,7 @@ func (b *Broker) ID() int32 {
|
|
|
return b.id
|
|
return b.id
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// Addr returns the broker address as either retrieved from Kafka's metadata or passed to NewBroker
|
|
|
|
|
|
|
+// Addr returns the broker address as either retrieved from Kafka's metadata or passed to NewBroker.
|
|
|
func (b *Broker) Addr() string {
|
|
func (b *Broker) Addr() string {
|
|
|
return b.addr
|
|
return b.addr
|
|
|
}
|
|
}
|