Add back in broker address

broker/broker.go

@@ -5,6 +5,7 @@ package broker
 type Broker interface {
 	Init(...Option) error
 	Options() Options
+	Address() string
 	Connect() error
 	Disconnect() error
 	Publish(topic string, m *Message, opts ...PublishOption) error

server/rpc_server.go

@@ -498,10 +498,9 @@ func (s *rpcServer) Start() error {
 		return err
 	}
 
-	baddr := strings.Join(config.Broker.Options().Addrs, ",")
 	bname := config.Broker.String()
 
-	log.Logf("Broker [%s] Connected to %s", bname, baddr)
+	log.Logf("Broker [%s] Connected to %s", bname, config.Broker.Address())
 
 	// use RegisterCheck func before register
 	if err = s.opts.RegisterCheck(s.opts.Context); err != nil {