티스토리 뷰

개발새발

카프카 EC2에 securityGroup 설정

LowBattery 2021. 8. 30. 11:17

현상1) EC2의 controller.log 에서 warning이 계속 발생

Controller 0's connection to broker 서버IP:9092 (id: 0 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)

현상2) 로컬에서 토픽리스트 조회시 timeout 에러 발생

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

메세지
ERROR java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Call(callName=listTopics, deadlineMs=1630289414320) timed out at 1630289414323 after 1 attempt(s)
	at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)

 

이유는 SecurityGroup에 로컬IP만 9092, 2181 접근하게 열어놨는데

그걸 모든IP 0000/0 과 ::/0 으로 설정했더니 되었다. 

공유기 문제일까? 

'개발새발' 카테고리의 다른 글

이직 1년  (0) 2022.08.16
새 직장, 새 업무  (0) 2021.09.14
1n년차 기술면접 후기 및 키워드 정리  (0) 2021.08.22
1n년차 개발자 이직기  (0) 2021.08.14
[Kafka] 토픽목록 조회 2가지 방법  (0) 2021.08.01
댓글
공지사항
최근에 올라온 글
최근에 달린 댓글
Total
Today
Yesterday
링크
«   2024/05   »
1 2 3 4
5 6 7 8 9 10 11
12 13 14 15 16 17 18
19 20 21 22 23 24 25
26 27 28 29 30 31
글 보관함