Kafka-Topic-설정 에러

XingXi·2024년 2월 25일
0

기록

목록 보기
16/33

1. Timed out waiting for a node assignment. Call: createTopics

카프카 토픽 생성 시 다음과 같은 예외가 발생하였다.


 ./bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic quickstart-events --partitions 1
Error while executing topic command : Timed out waiting for a node assignment. Call: createTopics
[2024-02-24 18:00:53,563] ERROR org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: createTopics
 (kafka.admin.TopicCommand$)

카프카 서버가 기동 된 상태에서 토픽을 생성하려고 했는데TIME OUT 이 발생했다. Zookeeper 와 kafka 생성 시 주소가 잘못 되었는지 확인했지만, 별 이상이 없었다.

2. server.properties 수정

카프카 서버 실행 시 설정 파일을 같이 실행 시키는데,
여기 설정을 수정해보았다.

수정 전 : server.properties

# The address the socket server listens on. If not configured, the host name will be equal to the value of
# java.net.InetAddress.getCanonicalHostName(), with PLAINTEXT listener name, and port 9092.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
#listeners=PLAINTEXT://:9092

수정 후 : server.properties

# The address the socket server listens on. If not configured, the host name will be equal to the value of
# java.net.InetAddress.getCanonicalHostName(), with PLAINTEXT listener name, and port 9092.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
listeners=PLAINTEXT://localhost:9092

Kafka 서버의 listener 설정이 주석 처리 되어 있어서 이를 수정하였다.

결과

이후 카프카 토픽이 잘 생성 된 것을 확인할 수 있다.

0개의 댓글