reset last error

8 months ago · 4e3701df77
1 changed files with 1 additions and 0 deletions
--- a/weed/mq/client/pub_client/scheduler.go
+++ b/weed/mq/client/pub_client/scheduler.go
@ -241,6 +241,7 @@ func (p *TopicPublisher) doConfigureTopic() (err error) {
 				return err
 			})
 		if err == nil {
 			lastErr = nil
 			return nil
 		} else {
 			lastErr = fmt.Errorf("%s: %v", brokerAddress, err)