java Kafka Connect+Zookepeer未连接

Question

我有一个kafka connect插件，部署在kafka集群中（在独立模式下，仅用于测试，目的是分布式完成）。这个卡夫卡连接插件使用curator连接到集群的zookeper，并从中提取一些信息，以决定如何处理这些消息

代码如下：

protected CuratorFramework getCurator(final String zkConnection) {
    final CuratorFramework curator = CuratorFrameworkFactory.newClient(zkConnection,
            new ExponentialBackoffRetry(1000, 3));
    curator.start();
    return curator;
}

treeCache = new TreeCache(curator, settings.getConfigurationRoot());
...
treeCache.start()

在treeCache启动时超时，配置根路径存在于本地zookeeper中（已确认在zookeeper外壳中执行ls，对于我尝试使用的zkConnection字符串：

• localhost:2181（zookeeper正在该端口中运行）
• localhost:2181，localhost:2182，localhost:2183
• ：2181
• ：2181，：2182，：2183
• 127.0.0.1:2181 ... 等等

在云中运行的卡夫卡流模块使用同一段代码与动物园管理员连接。。。知道这里发生了什么吗

谢谢

Answer 1

发现错误！我在try with resources语句中给那个getCurator打电话，这让策展人在开始treeCache之前关闭，一旦我将策展人移出try with resources语句并在sinkstask的stop方法中关闭它，一切都很好

干杯