Kafka连接Zookepeer不连接

Question

我有一个kafka connect插件，部署在kafka集群中（在独立模式下，仅用于测试，目的是分布式完成）。这个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正在该端口运行）

在云中运行的kafka流模块使用相同的代码与动物园管理员连接...知道这里发生了什么吗？

非常感谢。

Answer 1

发现错误！我调用getCurator在一个try-with资源语句，这是使馆长在启动treeCache之前关闭，一旦我将馆长移出try-with资源语句，并在Sink任务的停止方法中关闭它，一切正常。

干杯