zookeeper·kafka

kafka 원격 접속 안될때 no entry found for connection 1

초이짬 2018. 12. 7. 21:26
728x90



zookeeper 와 kafka 를 설치 후 (kafka_2.11-2.1.0) 서버에선 정상적으로 topic 생성 및 메시지 생성 확인이 다 이루어졋다


그래서 local 의 java에서도 2점대 kafka 라이브러리를 이용해서 컨슈머에서 접속 할려고 했는데(물론 포트 확인도 다 했고)


topic의 리스트는 받아오는데 poll 만 하면 no entry found for connection 1 에러가 떨어진다.


이해가 안가는게(소스도 공식설명에 나온 예제대로 작성햇고) consumer.listTopic 함수를 통해 데이터를 보면


서버에 있는 토픽은 목록에 있었다... 그럼 네트워크상의 데이터 접속도 문제(로컬에서 telnet 으로 port 오픈 확인)가 없는데


해서 혹시나 해서 java 소스를 서버상에 올려놓고 했더니 잘된다.


계속 찾아본 결과 server.properties 설정에


advertiesed.listner=PLAINTEXT://서버접속IP:9092 를 기입을 해야 된다.


이게 뭔고 하니 서버 ifconfig 상에는 실재 ip 가 192.168.10.** 으로 가상 IP 고 라우터를 거쳐 외부 IP에서 통신이 된다.


그래서 외부에서 접속 하는 IP 에 대해서 192대역인 사설 Ip 가 아닌 외부에서 접속 할때 쓰는 IP를 advertiesed.listner=PLAINTEXT://서버접속IP 에  박아주고 재기동 한후 원격지에서 호출하니 정상 동작이 되었다..








728x90