[kafka] kafka Install

 

Spring 에서 Kafka 를 테스트해보기전, 로컬에  Kafka 설치를 해야한다.

 

1. Kafka Script (Quick Install)

https://kafka.apache.org/downloads 에서 원하는 Kafka 버전을 선택하여 다운받는다.

 

저는 Kafka 2.8.0 버전을 다운받아 사용했습니다.

 

(윈도우 로컬에 설치할경우)

WSL 환경에서 실행시킬경우 bootstrap server 주소를 WSL IP 로 변경해줘야한다. (localhost X)

 

따라서 윈도우에서 설치후  아래 스크립트에서 .sh 를 .bat 으로 변경하여 사용하면된다.

 

# Run Zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties

# Run Kafka
bin/kafka-server-start.sh config/server.properties

# Create Topic
bin/kafka-topics.sh --create --topic coupon --bootstrap-server 172.30.10.31:9092

# Show List Topic
bin/kafka-topics.sh --list --zookeeper localhost:2181

# Describe Topic
bin/kafka-topics.sh --describe --topic coupon --bootstrap-server 172.30.10.31:9092

# Write Message
bin/kafka-console-producer.sh --topic coupon --bootstrap-server 172.30.10.31:9092

# Read Message
bin/kafka-console-consumer.sh --topic coupon --from-beginning --bootstrap-server 172.30.10.31:9092

# Remove Topic 
bin/kafka-topics.sh --delete --topic coupon --bootstrap-server 172.30.10.31:9092

 

 

2. Kafka docker-compose.yml

docker-compose 로 설치할수 있다.