diff --git a/jraft-core/src/main/java/com/alipay/sofa/jraft/RouteTable.java b/jraft-core/src/main/java/com/alipay/sofa/jraft/RouteTable.java index 94578a22f..1d37e6193 100644 --- a/jraft-core/src/main/java/com/alipay/sofa/jraft/RouteTable.java +++ b/jraft-core/src/main/java/com/alipay/sofa/jraft/RouteTable.java @@ -321,6 +321,11 @@ public Status refreshConfiguration(final CliClientService cliClientService, fina newPeer.parse(peerIdStr); newConf.addPeer(newPeer); } + for (final String learnerIdStr : resp.getLearnersList()) { + final PeerId newLearner = new PeerId(); + newLearner.parse(learnerIdStr); + newConf.addLearner(newLearner); + } if (!conf.equals(newConf)) { LOG.info("Configuration of replication group {} changed from {} to {}", groupId, conf, newConf); }