| commit | a70cf555fc49f8eea1a0ec2984102b9ef3e6ac75 | [log] [tgz] |
|---|---|---|
| author | guyinyou <36399867+guyinyou@users.noreply.github.com> | Fri Sep 10 11:20:40 2021 +0800 |
| committer | ShannonDing <libya_003@163.com> | Fri Sep 10 11:22:06 2021 +0800 |
| tree | 4f3f08ab6b4030cda506b79b89761b2931bf6755 | |
| parent | 29d789edcaa3408e569e96e76bd71591ee66dbe7 [diff] |
fix the bug caused in HA cluster in consumer (#723) (cherry picked from commit 406561060cb7d27c84df7f146a5ef003122c9cda)
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go index 08a1048..66bf367 100644 --- a/consumer/push_consumer.go +++ b/consumer/push_consumer.go
@@ -106,7 +106,7 @@ if err != nil { return nil, err } - + dc.namesrv = dc.option.ClientOptions.Namesrv p := &pushConsumer{ defaultConsumer: dc, subscribedTopic: make(map[string]string, 0),