[Kafka] Kafka 실행 실습

1. 리눅스 서버 3대 준비

- 메시지를 보낼 서버

- kafka, zookeepr 서버

- 메시지를 받을 서버

2. 세개 서버에 모두 kafka 다운로드 및 압축 풀기

- apache kafka download 검색 후 다운로드 주소 복사

- 서버에서 다운로드 및 압축 해제

wget https://dlcdn.apache.org/kafka/3.9.0/kafka_2.13-3.9.0.tgz
tar zxvf kafka_2.13-3.9.0.tgz

 

3. kafka는 java 기반 프레임 워크로 모든 서버에 java 다운로드

apt update
apt install openjdk-17-jdk

 

4. kafka 서버에 zookeeper & kafka 실행

- bin 폴더로 이동하여 zookeeper 실행

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

- config 폴더 이동하여 kafka 설정 변경

주석 처리된 listerners, advertised 주석 해제 및 advertised의 ip주소 kafka 서버로 변경

 

- bin 폴더 이동하여 kafka 실행

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

 

5. 메시지를 보낼 서버에서 producer 실행

- bin 폴더 이동하여 실행

./kafka-console-producer.sh --broker-list [kafka server ip]:9092 --topic abc

 

6. 메시지를 받을 서버에서 consumer 실행

- bin 폴더 이동하여 실행

./kafka-console-consumer.sh --bootstrap-server [kafka server ip]:9092 --topic abc

 

7. 메시지를 보낼 서버에서 메시지 입력 후 메시지를 받는 서버에서 메시지가 오는지 확인

메시지 전송

메시지 받기