fix the bug caused in HA cluster in consumer (#723)

guyinyou · ShannonDing · commit a70cf555fc49 · 2021-09-10T11:22:06.000+08:00
(cherry picked from commit 4065610)
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -106,7 +106,7 @@ func NewPushConsumer(opts ...Option) (*pushConsumer, error) {
 	if err != nil {
 		return nil, err
 	}
-
+	dc.namesrv = dc.option.ClientOptions.Namesrv
 	p := &pushConsumer{
 		defaultConsumer: dc,
 		subscribedTopic: make(map[string]string, 0),

Original file line number	Diff line number	Diff line change
`@@ -106,7 +106,7 @@ func NewPushConsumer(opts ...Option) (*pushConsumer, error) {`
`106`	`106`	`if err != nil {`
`107`	`107`	`return nil, err`
`108`	`108`	`}`
`109`		`-`
	`109`	`+ dc.namesrv = dc.option.ClientOptions.Namesrv`
`110`	`110`	`p := &pushConsumer{`
`111`	`111`	`defaultConsumer: dc,`
`112`	`112`	`subscribedTopic: make(map[string]string, 0),`