Skip to content

Commit

Permalink
feat(nameserver): correct impl of UpdateTopicRouteInfo (#406)
Browse files Browse the repository at this point in the history
default Topic is extra for UpdateTopicRouteInfo, and will cause incorrect config to retry topic.

Closes #404
  • Loading branch information
xujianhai666 authored Feb 12, 2020
1 parent 4f9013e commit 683c9ac
Showing 1 changed file with 4 additions and 7 deletions.
11 changes: 4 additions & 7 deletions internal/route.go
Original file line number Diff line number Diff line change
Expand Up @@ -118,13 +118,10 @@ func (s *namesrvs) UpdateTopicRouteInfo(topic string) (*TopicRouteData, bool) {

routeData, err := s.queryTopicRouteInfoFromServer(topic)
if err != nil {
routeData, err = s.queryTopicRouteInfoFromServer(defaultTopic)
if err != nil {
rlog.Warning("query topic route from server error", map[string]interface{}{
rlog.LogKeyUnderlayError: err,
})
return nil, false
}
rlog.Warning("query topic route from server error", map[string]interface{}{
rlog.LogKeyUnderlayError: err,
})
return nil, false
}

if routeData == nil {
Expand Down

0 comments on commit 683c9ac

Please sign in to comment.