diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go index 0b0ef564..63e9c54f 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 3676cb4c..1fbc48b5 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)