카프카를 실행할 서버 생성하기

ec2 프리티어 서버를 이용해 java, kafka 설치 진행

kafka broker heap memory 설정

카프카 브로커 : 레코드의 내용은 페이지 캐시로 시스템 메모리를 사용하고 나머지 객체들을 힙 메모리에 저장하여 사용

카프카 패키지의 힙 메모리 : 카프카 브로커 1G, 주키퍼 512MB 기본 설정

서버(t2.micro)의 메모리가 1G이기 때문에 기본 설정으로 실행할 수 없음

Cannot allocate memory 에러가 발생하게 됨

카프카 브로커 실행 옵션 설정

config/server.properties

advertised.listener : 카프카 클라이언트 또는 커맨드 라인 툴을 브로커와 연결할 때 사용

• advertised.listeners=PLAINTEXT://54.180.62.148:9092

주키퍼 실행

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

카프카 브로커 실행

bin/kafka-server-start.sh -daemon config/server.properties

브로커 로그 확인하기