2017-03-16 4 views
0

나는 kafka 및 사육사를 ec2 인스턴스에서 독립 실행 형 모드로 실행하고 있습니다. dev_spark1이라는 주제가 있습니다.kafka 소비자가 해당하는 동물원에 연결할 수 없습니다

./bin/kafka-console-consumer.sh 172.31.8.226:9092 --zookeeper --topic dev_spark1

Exception in thread "main" org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 6000 
     at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:880) 
     at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98) 
     at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84) 
     at kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:171) 
     at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:126) 
     at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:143) 
     at kafka.consumer.Consumer$.create(ConsumerConnector.scala:94) 
     at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:145) 
     at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala) 
: 나는 명령 줄에서 소비자를 실행하려고하지만, 명령에 대해 나에게 다음과 같은 오류를 제공합니다
+0

시도 증가 사육사 연결 시간 초과 속성을 사용하고 – mbaxi

+0

을 확인할 수 있습니까? 또한 로그에 DEBUG 레벨을 추가 할 수 있습니까? –

+0

나는 kafka_2.10-0.8.2.1이있다. 그리고 나는 사육사 연결 시간 제한을 특성 파일에서 6000에서 60000으로 증가 시켰지만 반영하지 않았다. –

답변

0

kafka가있는 컴퓨터에서 사육사 서버에 액세스 할 수 있습니까?

일반적으로 사육사는 포트 2181에서 수신 대기하고 kafka는 포트 9092에서 수신 대기합니다. 귀하의 명령에서 포트 9092의 172.31.8.226에있는 사육사와 연결하는 것이 정확합니다.

이것을 알아내는 다른 방법은 먼저 사육사 기계에서이 명령을 실행 한 다음 카프카 기계에서이 명령을 실행하고 연결하여 동물원을 시험해 볼 수 있는지 확인하십시오.

bin/zookeeper-shell.sh --zookeeper 172.31.8.226:9092 

당신은 UI를 실행할 수있는 능력을 가지고 있다면, 당신은 카프카의 어떤 버전을 사용합니까 ZooInspector

+0

사육사와 카프카는 모두 같은 기계에서 작동합니다. –

+0

나는 사육사 껍질에 연결할 수 있고 모든 중개인 및 그것의 화제를 목록으로 만들 수있다. 그러나 카프카 만이 사육사와 연결할 수 없습니다. –