fix the bug caused in HA cluster in pull_consumer (apache#717)

yanjianlong · Aug 23, 2021 · 78f607d · 78f607d
1 parent 0442864
commit 78f607d
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)
-Original file line number
+Diff line change
@@ Expand Up @@
     				return true
     			})
+    			rlog.Info("change the route for clients", nil)
     		}
     		s.routeDataMap.Store(topic, routeData)
@@ Expand Down @@