mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-01 15:47:01 +08:00
[ISSUE #4913] ReplicasManager#schedulingSyncControllerMetadata update controller metadata again after a while (#4914)
This commit is contained in:
@@ -377,6 +377,11 @@ public class ReplicasManager {
|
||||
if (flag) {
|
||||
this.scheduledService.scheduleAtFixedRate(this::updateControllerMetadata, 1000 * 3, this.brokerConfig.getSyncControllerMetadataPeriod(), TimeUnit.MILLISECONDS);
|
||||
return true;
|
||||
}
|
||||
try {
|
||||
TimeUnit.SECONDS.sleep(1);
|
||||
} catch (InterruptedException ignore) {
|
||||
|
||||
}
|
||||
tryTimes++;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user