Merge pull request #1 from apache/master

fix the bug caused in HA cluster in pull_consumer (apache#717)
yanjianlong · Aug 24, 2021 · 803b0b1 · 803b0b1
2 parents 0442864 + 78f607d
commit 803b0b1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go
@@ -93,7 +93,7 @@ func NewPullConsumer(options ...Option) (*defaultPullConsumer, error) {
 
 		namesrv: srvs,
 	}
-
+	dc.option.ClientOptions.Namesrv, err = internal.GetNamesrv(dc.client.ClientID())
 	c := &defaultPullConsumer{
 		defaultConsumer: dc,
 	}

diff --git a/internal/route.go b/internal/route.go
@@ -187,6 +187,7 @@ func (s *namesrvs) UpdateTopicRouteInfoWithDefault(topic string, defaultTopic st
 
 				return true
 			})
+			rlog.Info("change the route for clients", nil)
 		}
 
 		s.routeDataMap.Store(topic, routeData)