개요

로컬에서 kafka와 consumer를 같이 띄울때 잘 동작하던 로직이 kafka와 consumer가 원격으로 연결되자 연결은 정상적이지만 큐를 소비를 못하는 현상이 발생하였다.

해결방안

아래와 같이 kafka/server.properties에 advertised.host.name를 재설정 후 카프카를 재구동 해주니 문제가 해결되었다.

advertised.host.name=IP 혹은 호스트명

Reference

http://stackoverflow.com/questions/25558174/kafka-java-consumer-works-only-for-localhost-and-fails-for-remote-server