큐레이터 리더 선거 오류 동안 새로운 TestingServer() getConnectString에에서 지역 변경 ZK 연결 문자열에 연결 문자열이 아닌 새로운 TestingServer() getConnectString

Question

복사 샘플 코드. "호스트 : 포트", 점점 오류 :

ERROR org.apache.curator.framework.recipes.leader.LeaderLatch getChildren() failed. rc = -6 [main-EventThread]

.

코드 :

import org.apache.curator.framework.CuratorFramework 
import org.apache.curator.framework.CuratorFrameworkFactory 
import org.apache.curator.framework.recipes.leader.{LeaderLatch,LeaderLatchListener} 
import org.apache.curator.retry.ExponentialBackoffRetry 
import org.apache.curator.utils.CloseableUtils 
import java.io.BufferedReader 
import java.io.InputStreamReader 
import java.util 

object Main { 
    private val PATH = "/lead" 

    def main(args: Array[String]): Unit = { 
    val clients = new util.ArrayList[CuratorFramework] 
    val lists = new util.ArrayList[LeaderLatch]() 

    try { 
     for (i <- 0 to 2) { 
     val client = CuratorFrameworkFactory.newClient("xxxxx.org:2181", new ExponentialBackoffRetry(10000, 1)) 
     //val client = CuratorFrameworkFactory.newClient(new TestingServer().getConnectString, new ExponentialBackoffRetry(10000, 1)) 

     clients.add(client) 
     client.start() 
     client.blockUntilConnected() 

     val example = new LeaderLatch(client, PATH, i.toString) 
     lists.add(example) 

     example.start() 

     example.addListener(new LeaderLatchListener { 
      override def isLeader(): Unit = { 
      println(s"I am the lead $i") 
      } 

      override def notLeader(): Unit = { 
      println(s"i am not the leader any more $i") 
      } 
     }) 
     } 

     Thread.sleep(5000) 
     println("Press enter/return to quit\n") 
     new BufferedReader(new InputStreamReader(System.in)).readLine 
    } 
    finally { 
     System.out.println("Shutting down...") 
     import scala.collection.JavaConversions._ 
     for(example <- lists) 
     CloseableUtils.closeQuietly(example) 
     for (client <- clients) { 
     CloseableUtils.closeQuietly(client) 
     } 
    } 
    } 
} 

libs와 :

libraryDependencies += "org.apache.curator" % "apache-curator" % "4.0.0" 
libraryDependencies += "org.apache.curator" % "curator-framework" % "4.0.0" 
libraryDependencies += "org.apache.curator" % "curator-recipes" % "4.0.0" 
libraryDependencies += "org.apache.curator" % "curator-test" % "4.0.0" 
libraryDependencies += "org.apache.curator" % "curator-x-discovery" % "4.0.0" 
libraryDependencies += "org.apache.curator" % "curator-x-async" % "4.0.0" 

Answer 1

이 그것을 파악하지 이론에 의한 것도 있지만, 일했다. 3.4.10

그래서 그것은 버전 호환성 문제처럼 보인다 : 3.3.0

수동으로

• 변경 큐레이터 lib 디렉토리는 사육사에

사육사 버전/리드 노드를 작성합니다.

Answer 2

는 당신이 바로 사육사 의존성에게 큐레이터 종속성에서 exclude("org.apache.zookeeper","zookeeper"),

을 사육사를 제외하고 추가 할 필요가 "org.apache.zookeeper" % "zookeeper" % "3.4.9"

내 사육사 서버 3.4.9

입니다