Skip to content

Commit c9ca891

Browse files
authored
[ISSUE #845] support standard json
[ISSUE #845] support standard json
1 parent 2e1b335 commit c9ca891

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

internal/route.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -558,7 +558,8 @@ func (routeData *TopicRouteData) decode(data string) error {
558558
if i < 0 {
559559
continue
560560
}
561-
id, _ := strconv.ParseInt(str[0:i], 10, 64)
561+
brokerId := strings.ReplaceAll(str[0:i], "\"", "")
562+
id, _ := strconv.ParseInt(brokerId, 10, 64)
562563
bd.BrokerAddresses[id] = strings.Replace(str[i+1:], "\"", "", -1)
563564
}
564565
}

0 commit comments

Comments
 (0)