kafka topic 생성시 다음과 같은 에러가 발생했다.
error org.apache.kafka.common.errors.timeoutexception: the adminclient thread has exited. call: createtopics
해당 문구로 오류를 찾아봐도 해답을 찾을 수 없었다. 그래서 kafka 자체가 정상적으로 등록이 된건가 확인하니 host가 localhost가 아닌 다른 public ip로 등록되어 있었다.
INFO Registered broker 0 at path /brokers/ids/0 with addresses: PLAINTEXT://192.168.x.x:9092, czxid (broker epoch): 196 (kafka.zk.KafkaZkClient)
그래서 bootstrap-server를 localhost로 등록하려고 하니 찾을 수 없어서 에러가 발생했던 것이다.
localhost로 등록을 해주려면 kafka의 $kafka_home/config/server.properties를 수정해야 한다.
vi server.properties
vi의 find 명령어로 해당 부분 찾기 /listeners
listeners=PLAINTEXT://:9092
해당 부분을 다음과 같이 변경
listeners=PLAINTEXT://localhost:9092
그리고 다시 토픽 생성을 시도하면 이제 정상적으로 연결이 된다!