Kafka Connect + Zookepeer ne se connecte pas

Question

J'ai un plugin kafka connect qui est déployé dans un cluster kafka (en mode autonome, juste pour tester, l'idée est de le distribuer). Ce branchement de connexion kafka se connecte au zookeper de cluster en utilisant le conservateur et en tire des informations pour décider quoi faire avec les messages.

Le code est le suivant:

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() 

Il fois en ce début de TreeCache, le chemin racine de configuration existe dans Zookeeper local (confirmé faire un ls dans la Zookeeper-shell, et pour la chaîne de zkConnection I » ai essayé avec:

• localhost: 2181 (zookeeper est en cours d'exécution en ce que le port)
• localhost: 2181, localhost: 2182, localhost: 2183
• : 2181
• : 2181,: 2182,: 2183
• 127.0.0.1:2181 ... et ainsi de suite

Un module de courant de kafka fonctionnant dans un nuage se connecte avec cette zookeeper en utilisant le même morceau de code ... Une idée de ce qui se passe ici?

Merci!

Answer 1

Erreur trouvée! J'appelais getCurator dans une instruction try-with-resources et cela fermait le conservateur avant de lancer le treeCache, une fois que j'ai sorti le conservateur de l'instruction try-with-resources et l'ai fermé dans la méthode stop du SinkTask , tout a bien fonctionné.

À la votre!