diff --git a/weed/mq/client/pub_client/scheduler.go b/weed/mq/client/pub_client/scheduler.go index 93d0d4c9e..e6caf896c 100644 --- a/weed/mq/client/pub_client/scheduler.go +++ b/weed/mq/client/pub_client/scheduler.go @@ -223,7 +223,7 @@ func (p *TopicPublisher) doConfigureTopic() (err error) { if err == nil { return nil } else { - lastErr = err + lastErr = fmt.Errorf("%s: %v", brokerAddress, err) } }