Kafka에 메시지 넣기 / Kafka에서 메시지 조회하기

JSCODE 박재성

2025-12-06

✅ Kafka에 메시지 넣기

1. 토픽 생성

# email.send라는 토픽 생성
$ bin/kafka-topics.sh \
	--bootstrap-server localhost:9092 \
	--create --topic email.send

 

2. Kafka의 특정 토픽에 메시지 넣기
Kafka에 넣는 메시지는 Key-Value 형태로 넣을 수도 있고, Key는 생략한 채로 Value만 넣을 수도 있다. 우선 Key를 생략한 채로 Value만 넣는 방식을 배워보자.

# email.send라는 토픽에 메시지 넣기
$ bin/kafka-console-producer.sh \
	--bootstrap-server localhost:9092 \
	--topic email.send

# 위 명령어 입력 후 넣을 메시지 내용 입력하고 Enter 누르기
hello1
hello2
hello3

# 입력 다 했으면 Ctlr + c로 입력 상태 종료하기

아무런 에러가 뜨지 않았다면 토픽에 메시지가 잘 들어간 것이다. 이제 토픽에 넣은 메시지를 조회하는 방법에 대해 알아보자.

✅ Kafka에서 메시지 조회하기

1. 특정 토픽에 쌓인 메시지 전부 조회하기 + 실시간으로 메시지 조회하기

# email.send라는 토픽에 있는 메시지 꺼내기
$ bin/kafka-console-consumer.sh \
	--bootstrap-server localhost:9092 \
	--topic email.send \
	--from-beginning

• --from-beginning : 토픽에 저장된 가장 처음 메시지부터 출력해온다.

2. 토픽에 메시지 추가하기

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

# 위 명령어 입력 후 넣을 메시지 내용 입력하고 Enter 누르기
hello4



email.send 토픽에 메시지를 넣자마자, email.send 토픽의 메시지를 조회하고 있는 터미널 창에서 실시간으로 메시지를 읽어오는 걸 확인할 수 있다.
 

3. 메시지를 다시 읽어올 수 있는 지 확인하기

# 아래 명령어 다시 입력해보기
$ bin/kafka-console-consumer.sh \
	--bootstrap-server localhost:9092 \
	--topic email.send \
	--from-beginning

만약 Kafka가 메시지를 꺼내서 읽는 순간 메시지를 삭제하는 방식이었다면, 다시 메시지를 조회하는 명령어를 입력했을 때 메시지가 조회되지 않아야 한다. 하지만 아래 명령어를 입력해보면 정상적으로 메시지를 잘 읽어오는 걸 확인할 수 있다.
이로써 Kafka는 메시지를 읽고 제거하는 방식이 아니라, 저장되어 있는 메시지를 읽기만 하고 제거하지 않는 방식이라는 걸 알 수 있었다.