[실습] 프로젝트 구조에 맞게 Kafka 셋팅하기

JSCODE 박재성

2025-12-06

✅ 프로젝트 구조에 맞게 Kafka 셋팅하기

1. Kafka랑 연결되어 있는 Spring Boot 서버 종료하기
 

2. 기존에 셋팅해뒀던 카프카 서버 3대를 백그라운드에서 실행시키기

$ bin/kafka-server-start.sh -daemon config/server.properties
$ bin/kafka-server-start.sh -daemon config/server2.properties
$ bin/kafka-server-start.sh -daemon config/server3.properties

# 잘 작동하는 지 확인하기
$ lsof -i:9092
$ lsof -i:19092
$ lsof -i:29092

2. 기존에 생성되어 있던 토픽 삭제하기
깔끔한 테스트를 위해 기존에 생성되어 있는 모든 토픽을 삭제하자.

# 전체 토픽 조회
$ bin/kafka-topics.sh \
	--bootstrap-server localhost:9092 \
	--list
	
# 조회된 모든 토픽 삭제하기
$ bin/kafka-topics.sh \
	--bootstrap-server localhost:9092 \
	--delete --topic <토픽명>

 

4. 토픽 생성하기

$ bin/kafka-topics.sh \
	--bootstrap-server localhost:9092 \
	--create \
	--topic user.signed-up \
	--partitions 3 \
	--replication-factor 3
	

# 토픽 세부 정보 조회 (잘 생성됐는 지 확인하기)
$ bin/kafka-topics.sh \
  --bootstrap-server localhost:9092 \
  --describe \
  --topic user.signed-up

병렬 처리와 고가용성을 위해 파티션 3개와 레플리케이션 3개를 가지게 토픽을 생성하자.
 

3. DLT 토픽 생성하기
DLT 토픽도 미리 생성해주자.

$ bin/kafka-topics.sh \
	--bootstrap-server localhost:9092 \
	--create \
	--topic user.signed-up.dlt \
	--partitions 1 \
	--replication-factor 3
	
# 토픽 세부 정보 조회 (잘 생성됐는 지 확인하기)
$ bin/kafka-topics.sh \
  --bootstrap-server localhost:9092 \
  --describe \
  --topic user.signed-up.dlt

DLT 토픽에 쌓이는 메시지는 빠르게 처리할 필요 없으므로 파티션을 1개만 만들자. 하지만 메시지가 손실되지 않게 복제해두는 건 중요하기 때문에 레플리케이션을 3으로 설정하자.