Kafka TimeoutException 해결 방법

 

ZooKeeper를 사용한 카프카

- Kafka를 사용하다가 발생한 TimeoutException 을 해결하는 방법입니다.

Zookeeper 및 Kafka 서버 기동

# Start the Kafka broker service
$ bin/kafka-server-start.sh config/server.properties

 

다음 실행 명령을 통해 zookeeper 서버가 port 2181으로 구동된 것을 확인하였고, kafka 서버 역시 port 9092 번으로 started 된 것을 확인하였습니다.

 

이벤트를 저장할 주제 만들기

하지만 서버가 실행 후 주제를 만들어 주기 위해서 아래 명령어를 작성하였지만 create 문구가 뜨는게 아니라 아래 에러 문구가 떴습니다.

 

- 주제 생성 코드

bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

 

- 에러 문구

ERROR org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: createTopics
 (org.apache.kafka.tools.TopicCommand)
jinseonghyeon@jinseonghyeon-ui-MacBookPro kafka_server % bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Error while executing topic command : Timed out waiting for a node assignment. Call: createTopics

 

 해결

- 원인 파악을 위해 서버가 기동 된 로그를 살피던 중 'PLAINTEXT://218.xx.137.xx:9092'라는 부분을 발견하여서

kafka 서버가 기동은 되었지만 localhost:9092로 접근할 수 있도록 허용되지 않은 것 같았습니다.

 

- 이를 해결하기 위해 아래 경로에 있는 파일인 server.properties file 에서 아래 코드를 추가 해 주어서 포트번호에 접근을 할 수 있게 허용을 해주었습니다.

//kafka_server > config > server.properties file 

 

- 추가 코드

listeners=PLAINTEXT://localhost:9092

 

 

이후 다시 주제 생성 코드를 작성해 보면 아래 문구가 뜨면서 잘 생성 된 것을 볼 수 있습니다.

Created topic quickstart-events.