나는 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)
: 나는 명령 줄에서 소비자를 실행하려고하지만, 명령에 대해 나에게 다음과 같은 오류를 제공합니다
시도 증가 사육사 연결 시간 초과 속성을 사용하고 – mbaxi
을 확인할 수 있습니까? 또한 로그에 DEBUG 레벨을 추가 할 수 있습니까? –
나는 kafka_2.10-0.8.2.1이있다. 그리고 나는 사육사 연결 시간 제한을 특성 파일에서 6000에서 60000으로 증가 시켰지만 반영하지 않았다. –