Kafka Install

- java설치

$ sudo apt-get install openjdk-17-jdk

- 카프카 다운로드

$ wget https://downloads.apache.org/kafka/3.5.0/kafka_2.13-3.5.0.tgz

(https://downloads.apache.org/kafka/3.5.0/kafka_2.13-3.5.0.tgz)

- 카프카 실행

$ ./kafka_2.13-3.5.0/bin/zookeeper-server-start.sh ./kafka_2.13-3.5.0/config/zookeeper.properties
$ ./kafka_2.13-3.5.0/bin/kafka-server-start.sh ./kafka_2.13-3.5.0/config/server.properties  
$ ./kafka_2.13-3.5.0/bin/kafka-server-start.sh ./kafka_2.13-3.5.0/config/server02.properties

- 토픽생성

$ ./kafka_2.13-3.5.0/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 2 --topic test01

- 토픽확인

$ ./kafka_2.13-3.5.0/bin/kafka-topics.sh --list --bootstrap-server localhost:9092  
$ ./kafka_2.13-3.5.0/bin/kafka-topics.sh --describe --bootstrap-server localhost:9092

- 메시지 전송

$ ./kafka_2.13-3.5.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test01

- 메지시 받기

$ ./kafka_2.13-3.5.0/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test01 --from-beginning

- 카프카 종료

$ ./kafka_2.13-3.5.0/bin/kafka-server-stop.sh  
$ ./kafka_2.13-3.5.0/bin/zookeeper-server-stop.sh

- server.properties 설정

listeners=PLAINTEXT://:9092  
advertised.listeners=PLAINTEXT://43.200.20.154:9092

- zookeeper.properties 설정

advertised.listeners=PLAINTEXT://54.180.81.28:9092  
zookeeper.connect=localhost:2181