[1] Kafka 다운로드하기

Download : kafka_2.13-3.4.0.tgz
1. 위 링크로 이동하면 아래 화면이 나온다.
2. 아래 빨간색 네모박스를 클릭하여 tgz 파일을 다운로드한다.

다운로드 받은 파일을 WSL Ubuntu에 복사한다.

$ tar -xzf kafka_2.13-3.4.0.tgz
$ cd kafka_2.13-3.4.0

해당 커맨드로 압축 해제후에 해당 폴더로 이동

NOTE : WSL Ubuntu에 자바 8+가 설치되어 있어야 한다.

[2] Kafka 환경 구성하기

ZooKeeper를 이용하여 서비스를 환경을 구성.

# Start the ZooKeeper service
$ bin/zookeeper-server-start.sh config/zookeeper.properties

터미널 하나를 더 열고 아래 커맨드 실행

# Start the Kafka broker service
$ bin/kafka-server-start.sh config/server.properties

[3] Topic 생성하기

1. TOPIC_NAME 대신 원하는 토픽명을 넣고 커맨드 입력하면 아래와 같이 생성이 확인됨

$ bin/kafka-topics.sh --create --topic TOPIC_NAME --bootstrap-server localhost:9092

2. 생성된 토픽 목록 확인

$ bin/kafka-topics.sh --list --bootstrap-server localhost:9092

3. 토픽 상세내역 확인

$ bin/kafka-topics.sh --describe --topic daniel-event01 --bootstrap-server localhost:9092

[4] 생성한 토픽으로 통신 테스트

터미널 창 2개를 새로 열고 한쪽은 Producer, 다른 한쪽은 Consumer를 실행

1. producer
   커맨드 입력 후 아래 2개의 문구 작성 후 ctrl+c를 눌러 빠져나온다.

$ bin/kafka-console-producer.sh --topic TOPIC_NAME --bootstrap-server localhost:9092
>This is my first event
>This is my second event

2. consumer
   producer 커맨드로 입력된 문구를 확인 할 수 있다. ctrl+c를 눌러 빠져나온다.

$ bin/kafka-console-consumer.sh --topic TOPIC_NAME --from-beginning --bootstrap-server localhost:9092

---

출처
https://kafka.apache.org/quickstart
https://itstudy402.tistory.com/59