diff --git a/spring-cloud-kubernetes-leader/src/main/java/org/springframework/cloud/kubernetes/leader/LeaderAutoConfiguration.java b/spring-cloud-kubernetes-leader/src/main/java/org/springframework/cloud/kubernetes/leader/LeaderAutoConfiguration.java index 44801d2b..f4ffe984 100644 --- a/spring-cloud-kubernetes-leader/src/main/java/org/springframework/cloud/kubernetes/leader/LeaderAutoConfiguration.java +++ b/spring-cloud-kubernetes-leader/src/main/java/org/springframework/cloud/kubernetes/leader/LeaderAutoConfiguration.java @@ -66,14 +66,8 @@ public class LeaderAutoConfiguration { throws UnknownHostException { Candidate candidate = getCandidate(leaderProperties); ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(); - LeaderInitiator leaderInitiator = - new LeaderInitiator(leaderProperties, leadershipController, candidate, scheduledExecutorService); - if (leaderInitiator.isAutoStartup()) { - leaderInitiator.start(); - } - - return leaderInitiator; + return new LeaderInitiator(leaderProperties, leadershipController, candidate, scheduledExecutorService); } private Candidate getCandidate(LeaderProperties leaderProperties) throws UnknownHostException {