카프카는 데이터를 받아서 전달하는 데이터 버스의 역할을 한다. 카프카에 데이터를 만들어서 주는 쪽을 프로듀서, 카프카에서 데이터를 빼내서 소비하는 쪽을 컨슈머라고 한다. 주키퍼는 카프카의 정상 동작을 보장하기 위해 메타데이터를 관리하는 코디네이터라고 할 수 있다.
메시지 보내고 받기 위해서는 우선 토픽을 생성해야 한다.
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
프로듀서를 실행하면 ">" 명령 프롬프트 노출됩니다. 여기서 메시지를 입력하면 즉시 카프카의 토픽으로 전송됩니다. 해당 메시지는 컨슈머에서 소비하게 되고 컨슈머에서 해당 메시지가 노출 됩니다.