3장. 카프카 설치

이 장에서는 카프카 클러스터 환경을 구축하고 프로듀서에서 컨슈머로 메시지를 보내는 실습을 했다.

카프카 클러스터 구성은 서버 3대로 카프카 클러스터, 프로듀서와 컨슈머 그리고 카프카 클라이언트로 구성했다. 카프카 컨플루언트를 사용했고 자바는 openjdk1.8로 구성했다.

나는 가상머신으로 작업을 했는데 첫 구축 완료 후 카프카 클러스터가 제대로 동작하나 server.log를 확인했는데 제대로 작동이 안되고 있었다. 원인을 확인해보니 카프카 클러스터끼리 연동이 안되고 있었다. 생각해보니 가상머신의 방화벽에서 포트를 열어주지 않았고 그래서 카프카 클러스터끼리 연동이 되지 않는 것이었다. 열어야하는 포트를 다 열고 다시 카프카 클러스터를 동작시키니 성공이라는 로그를 찍고 제대로 동작했다.

그래서 프로듀서와 컨슈머를 실행하고 프로듀서에서 컨슈머로 메시지를 보내봤다. 이번에는 컨슈머에서 아래와 같은 경고 메시지를 엄청나게 출력하고 있었다.

kafka broker may not be available

원인은 server.properties에서 advertised.listeners 설정이 주석처리 되어있어서였다. advertised.listeners=PLAINTEXT://your.host.name:9092를 주석해제하고 내 IP를 적어넣고 다시 메시지를 보내니 제대로 되었다.