Apache Kafka (2) - 프로듀서 및 컨슈머

Wondeok Kang (a.k.a. Wade)·2022년 4월 8일
0

Apache Kafka Study

목록 보기
2/2
post-thumbnail

1. 개요

두번째 포스트로 카프카에서 제공하는 콘솔 프로듀서와 컨슈머로 메시지를 발행 & 구독하는 과정을 정리한다.
생각보다 매우 간단하다.

2. 프로듀서

카프카에 메시지를 발행하는 역할을 한다. 대부분 사람들이 Producer라고 명명하지만 Sender라고 사용하기도 한다.
이번 포스트에서는 카프카에서 기본적으로 제공해주는 console producer를 사용한다.

deogicorgi ~/Development/software/kafka_2.13-3.1.0 > ./bin/kafka-console-producer.sh --topic deogicorgi-topic-1 --bootstrap-server localhost:9092

위와 같이 입력하게 되면 아래와 같이 메시지를 발행할수 있는 환경이 만들어진다.

>

세개의 메시지를 발행해보았다.

>hello deogicorgi
>hello kafka
>hello my topic!

3. 컨슈머

프로듀서를 이용하여 메시지를 발행했으니 컨슈머로 메시지를 구독해본다.
컨슈머 역시 카프카에서 기본적으로 제공해주는 console consumer를 사용한다.

deogicorgi ~/Development/software/kafka_2.13-3.1.0 > ./bin/kafka-console-consumer.sh --topic deogicorgi-topic-1 --from-beginning --bootstrap-server localhost:9092
hello deogicorgi
hello kafka
hello my topic!

커맨드를 수행하자마자 프로듀서에서 보냈던 메시지 3개가 수신된다. 기본적으로 console consumer는 실행 이후부터 발행된 메시지만을 수신하지만 --from-beginning 옵션으로 인하여 토픽 내 모든 메시지를 수신하게 되었다.

profile
최고의 개발도구는 기록과 구글링이다.

0개의 댓글