diff --git a/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java b/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java index 7b53ee97..f9673778 100644 --- a/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java +++ b/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java @@ -374,6 +374,10 @@ public class ZookeeperRegistry implements IRegistry { @Override public void checkConsumer() { + if (curator == null) { + return; + } + if (curator.getState() == CuratorFrameworkState.STOPPED) { return; }