5분만에 카프카 맛보고 뱃기

런던행·2022년 2월 7일
0

카프카

목록 보기
2/4

카프카의 기본구성

카프카는 데이터를 받아서 전달하는 데이터 버스의 역할을 한다. 카프카에 데이터를 만들어서 주는 쪽을 프로듀서, 카프카에서 데이터를 빼내서 소비하는 쪽을 컨슈머라고 한다. 주키퍼는 카프카의 정상 동작을 보장하기 위해 메타데이터를 관리하는 코디네이터라고 할 수 있다.

메시지 보내고 받기

메시지 보내고 받기 위해서는 우선 토픽을 생성해야 한다.

토픽 생성

peter-overview01 토픽을 생성한다.

./bin/kafka-topics.sh --create --topic peter-overview01 --bootstrap-server 127.0.0.1:9092

컨슈머 실행

./bin/kafka-console-consumer.sh --topic peter-overview01 --bootstrap-server localhost:9092

프로듀서 실행

./bin/kafka-console-producer.sh --topic peter-overview01 --bootstrap-server 127.0.0.1:9092

실행하기

프로듀서를 실행하면 ">" 명령 프롬프트 노출됩니다. 여기서 메시지를 입력하면 즉시 카프카의 토픽으로 전송됩니다. 해당 메시지는 컨슈머에서 소비하게 되고 컨슈머에서 해당 메시지가 노출 됩니다.

profile
unit test, tdd, bdd, laravel, django, android native, vuejs, react, embedded linux, typescript

0개의 댓글