보안 그룹 생성
Kafka 9092
주키퍼 2181
인스턴스 자바 설치
$ sudo yum install -y java-1.8.0-openjdk-devel.x86_64
카프카 설치
$ wget https://archive.apache.org/dist/kafka/2.5.0/kafka_2.12-2.5.0.tgz
$ tar xvf kafka_2.12-2.5.0.tgz
cd kafka_2.12-2.5.0
힙 메모리 설정
$ vi ~/.bashrc
추가
export KAFKA_HEAP_OPTS="-Xmx400m -Xms400m"
$ source ~/.bashrc
카프카 브로커 실행 옵션 설정
vi config/server.properties
주석을 제거하고 your.host.name에 ip를 넣어준다.
advertised.listeners=PLAINTEXT://your.host.name:9092
주키퍼 실행
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
jps -vm
카파카 실행
bin/kafka-server-start.sh -daemon config/server.properties
jps -m
tail -f logs/server.log
로컬에서 확인
$ curl https://archive.apache.org/dist/kafka/2.5.0/kafka_2.12-2.5.0.tgz --output kafka.tgz
tar -xvf kafka.tgz
etc/hosts 에서 my-kafka 로 등록
bin/kafka-topics.sh --bootstrap-server my-kafka:9092 --list