diff --git a/spring/boot-starter/src/main/java/org/apache/shardingsphere/elasticjob/spring/boot/reg/ElasticJobRegistryCenterConfiguration.java b/spring/boot-starter/src/main/java/org/apache/shardingsphere/elasticjob/spring/boot/reg/ElasticJobRegistryCenterConfiguration.java index c6b749c344..7e383a0346 100644 --- a/spring/boot-starter/src/main/java/org/apache/shardingsphere/elasticjob/spring/boot/reg/ElasticJobRegistryCenterConfiguration.java +++ b/spring/boot-starter/src/main/java/org/apache/shardingsphere/elasticjob/spring/boot/reg/ElasticJobRegistryCenterConfiguration.java @@ -33,7 +33,7 @@ public class ElasticJobRegistryCenterConfiguration { * @param zookeeperProperties factory * @return zookeeper registry center */ - @Bean(initMethod = "init") + @Bean(initMethod = "init", destroyMethod = "close") public ZookeeperRegistryCenter zookeeperRegistryCenter(final ZookeeperProperties zookeeperProperties) { return new ZookeeperRegistryCenter(zookeeperProperties.toZookeeperConfiguration()); }