From 78f607d2a200bda1d1e69151e1b742316c796a19 Mon Sep 17 00:00:00 2001
From: guyinyou <36399867+guyinyou@users.noreply.github.com>
Date: Mon, 23 Aug 2021 20:45:31 +0800
Subject: [PATCH] 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 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)