diff options
| author | chrislu <chris.lu@gmail.com> | 2024-03-07 10:44:09 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-03-07 10:44:09 -0800 |
| commit | 33ab6cfcf783c8b8c78da7220a6d9474615199c9 (patch) | |
| tree | 58db5e61834c669e3a30c5204d2ca02f385dd931 | |
| parent | 8f79bb398780a5b0e746c2be4160e74dcc65b287 (diff) | |
| download | seaweedfs-33ab6cfcf783c8b8c78da7220a6d9474615199c9.tar.xz seaweedfs-33ab6cfcf783c8b8c78da7220a6d9474615199c9.zip | |
adjust error
| -rw-r--r-- | weed/mq/client/pub_client/scheduler.go | 2 |
1 files changed, 1 insertions, 1 deletions
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) } } |