echooymxq opened a new issue, #5009: URL: https://github.com/apache/rocketmq/issues/5009
The current change BrokerRole implementation is detects the broker's heartbeat periodically. https://github.com/apache/rocketmq/blob/10e8e6b8ae565095cfa6c70fa07857e526a20d0d/controller/src/main/java/org/apache/rocketmq/controller/impl/DefaultBrokerHeartbeatManager.java#L77-L86 The above code, `iterator.remove()` remove first and with async notify mechanism to elect a master, if there are any failure or timeout(eg: write to DLedger error), no retry mechanism, The broker always have no leader? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
