问题
使用elstic-job时,zk注册有问题,报错如下:

@Bean(initMethod = "init")
public ZookeeperRegistryCenter regCenter(@Value("${regCenter.serverList}") final String serverList,
@Value("${regCenter.namespace}") final String namespace) {
return new ZookeeperRegistryCenter(new ZookeeperConfiguration(serverList, namespace));
}
解决方案
更改zk的连接方式,采用CoordinatorRegistryCenter
@Bean(initMethod = "init")
public CoordinatorRegistryCenter regCenter(@Value("${regCenter.serverList}") final String serverList,
@Value("${regCenter.namespace}") final String namespace) {
ZookeeperConfiguration zkConfig = new ZookeeperConfiguration(serverList, namespace);
zkConfig.setMaxSleepTimeMilliseconds(60000); //设置最大超时时间,默认 3*3000- 9S可能不满足
CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(zkConfig);
regCenter.init();
return regCenter;
}```
版权声明:本文为qq_36094023原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。