This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 78f607d fix the bug caused in HA cluster in pull_consumer (#717)
78f607d is described below
commit 78f607d2a200bda1d1e69151e1b742316c796a19
Author: guyinyou <[email protected]>
AuthorDate: Mon Aug 23 20:45:31 2021 +0800
fix the bug caused in HA cluster in pull_consumer (#717)
---
consumer/pull_consumer.go | 2 +-
internal/route.go | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go
index 0b0ef56..63e9c54 100644
--- 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
index 3676cb4..1fbc48b 100644
--- 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)
