[Kafka] 토픽목록 조회 2가지 방법

AWS에 설치했고 서버에 들어가서 토픽 만들고 확인하는 방법

 

1. 주키퍼로 확인하는 방법

>bin/kafka-topics.sh --list --zookeeper localhost:2181
test

2. 카프카로 확인하는 방법

> bin/kafka-topics.sh --bootstrap-server=localhost:9092 --list
Error while executing topic command : org.apache.kafka.common.errors.TimeoutException: Call(callName=listTopics, deadlineMs=1627799910566) timed out at 1627799910568 after 1 attempt(s)

나의 경우 주키퍼로는 확인이 가능한데

카프카로 하면 계속 에러가 나는 현상이 있었다.

 

controller.log에도 아래와 같은 로그가 찍히고 있었다.

WARN [RequestSendThread controllerId=1] Controller 1's connection to broker {아이피}:9092 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread)
java.net.SocketTimeoutException: Failed to connect within 30000 ms
	at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:289)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:242)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)

 

이유는 AWS Security Group에 9092를 안열고 9091로 오타로 넣어들어갔던거.

 

로컬에서도 접속 잘 된다.

bin/kafka-topics.sh --bootstrap-server my-kafka:9092 --list

 

흑...