This is an automated email from the ASF dual-hosted git repository. yuzhou pushed a commit to branch yuz10-patch-1 in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
commit f0ef089e1c02af305841dc7dd71592c3b2f49c62 Author: yuz10 <[email protected]> AuthorDate: Thu Jun 16 22:11:35 2022 +0800 support standard json --- internal/route.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/route.go b/internal/route.go index a101a61..715c64f 100644 --- a/internal/route.go +++ b/internal/route.go @@ -558,7 +558,8 @@ func (routeData *TopicRouteData) decode(data string) error { if i < 0 { continue } - id, _ := strconv.ParseInt(str[0:i], 10, 64) + brokerId := strings.ReplaceAll(str[0:i], "\"", "") + id, _ := strconv.ParseInt(brokerId, 10, 64) bd.BrokerAddresses[id] = strings.Replace(str[i+1:], "\"", "", -1) } }
