fix(consumer): brokerName not found when broker recover from machine crash. (#429)
when broker recover from machine creash, current routeData is not changed due to bug, which should be "change" as expected. then, mq can not be consumed or consuming mq can not update offset.
diff --git a/internal/route.go b/internal/route.go
index 8270a8c..a1a3f79 100644
--- a/internal/route.go
+++ b/internal/route.go
@@ -28,7 +28,7 @@
"sync/atomic"
"time"
- "github.com/json-iterator/go"
+ jsoniter "github.com/json-iterator/go"
"github.com/tidwall/gjson"
"github.com/apache/rocketmq-client-go/v2/internal/remote"
@@ -595,6 +595,10 @@
return false
}
+ if len(b.BrokerAddresses) != len(bd.BrokerAddresses) {
+ return false
+ }
+
for k, v := range b.BrokerAddresses {
if bd.BrokerAddresses[k] != v {
return false
