2016-06-29 3 views
4

동일한 컴퓨터에서 실행중인 Kafka 브로커에 Kafka 콘솔 제작자를 사용하여 메시지를 보내려고합니다. 카프카 브로커가 포트 9092에서 수신 대기하는 경우에 나는 검사 할 때, 거기 및 실행kafka-console-producer.sh TimeOutException

[2016-06-29 15:00:44,069] ERROR Error when sending message to topic test with key: null, value: 11 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) 
org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for test-0 

: 나는

echo "Hello world" | ./kafka-console-producer.sh --broker-list localhost:9092 --topic test 

을 실행할 때 나는 다음과 같은 오류 메시지가 나타납니다. 명령 줄 작성자가 브로커에 연결할 수없는 이유를 디버깅하려면 어떻게해야합니까? 고맙습니다!

+0

업데이트 로거 수준 : 기본값을 사용하는 경우 즉은, 이름은 '/ 브로커'하고 명령해야한다. 디버깅 할 수없는 경우 여기에 붙여 넣으십시오. –

+0

ZK가 올바르게 작동합니까? –

답변

1

나는 동일한 문제를 경험했으며, 카프카가 동물원에 잘못된 메타 데이터를 작성한 것으로 보입니다.

가장 간단한 방법은 브로커 데이터가 등록되는 z 노드를 제거하는 것입니다. `설정/도구 - log4j.properties`에서 추적하고 명령을 실행 WARN에서

$ zkCli.sh 
... 
[zk: localhost:2181(CONNECTED) 1] rmr /brokers 
관련 문제