[실습] Spring Boot가 Kafka에 메시지 잘 넣는 지 테스트해보기

JSCODE 박재성

2025-12-06T05:14:00Z

✅ 깔끔한 테스트를 위해 기존에 생성되어 있는 Kafka 리소스 삭제하기

1. 전체 토픽 조회하기

# 전체 토픽 조회하기
$ bin/kafka-topics.sh \
	--bootstrap-server localhost:9092 \
	--list



토픽을 조회해보면 이전에 생성했던 email.send 토픽이 조회되는 걸 확인할 수 있다.
 

2. 토픽 삭제하기
이전에 생성했던 email.send 토픽을 삭제하자.

# 토픽 삭제
$ bin/kafka-topics.sh \
	--bootstrap-server localhost:9092 \
	--delete --topic email.send
	
# 잘 삭제됐는 지 확인하기
$ bin/kafka-topics.sh \
	--bootstrap-server localhost:9092 \
	--list

 

3. 전체 컨슈머 그룹 조회하기

# 전체 컨슈머 그룹 조회하기
$ bin/kafka-consumer-groups.sh \
	--bootstrap-server localhost:9092 \
	--list



 

4. 컨슈머 그룹 삭제하기
이전에 생성했던 email-send-group이라는 컨슈머 그룹을 삭제하자.

# 컨슈머 그룹 삭제
$ bin/kafka-consumer-groups.sh \
	--bootstrap-server localhost:9092 \
	--delete \
	--group email-send-group
	
# 잘 삭제됐는 지 확인하기
$ bin/kafka-consumer-groups.sh \
	--bootstrap-server localhost:9092 \
	--list

 

5. 토픽 다시 생성하기
email.send 토픽에 메시지를 넣어서 테스트를 해봐야하기 때문에 email.send 토픽을 다시 생성해주자.

# 토픽 생성
$ bin/kafka-topics.sh \
	--bootstrap-server localhost:9092 \
	--create --topic email.send
	
# 토픽 잘 생성됐는 지 확인하기
$ bin/kafka-topics.sh \
	--bootstrap-server localhost:9092 \
	--list

✅ Spring Boot가 Kafka에 메시지 잘 넣는 지 테스트해보기

1. Spring Boot 서버 실행시키기



 

2. API 요청 보내기
API 요청을 보내서 Kafka에 메시지가 잘 들어가는 지 확인해보자. 요청을 보낼 때 Postman이라는 툴을 활용할 것이다. 다른 API 요청 툴이 있다면 꼭 Postman을 쓰지 않아도 된다.



요청을 보낸 뒤에 성공적으로 응답이 날라온 것까지 확인했다.
 

3. Kafka의 email.send 토픽에 메시지가 잘 들어갔는 지 확인하기

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



토픽으로부터 메시지가 잘 조회되는 걸로 봐서 Kafka의 email.send 토픽에 메시지가 잘 들어갔다는 걸 알 수 있다.
 
 

✅ 그림 보면서 전체 흐름 정리하기