🔨Kafka 설치

https://kafka.apache.org/downloads 에 접근하여 다운 받으면 된다.

압축을 풀고 bin 내부에 파일을 확인하면 여러 Shell Script가 존재한다.
window의 경우 windows 내부의 bat 파일을 실행하면 된다.

window의 경우 kafka 3.0 이상 버전에서는 에러가 발생한다 2.8.1 버전을 사용하는 것을 추천한다.

👏Kafka 실행해보기

./bin/windows/zookeeper-server-start.bat ./config/zookeeper.properties

/프로젝트경로/kafka폴더에서 명령창을 킨 후 명령어를 입력하면

정상적으로 zookeaper server가 실행되었다.

zookeaper는 kafka에 코디네이터 개념인데. 나도 잘 모르니 일단 따라가보자

./bin/windows/kafka-server-start.bat ./config/server.properties

다른 명령창에서 해당 명령어를 실행하자

kafka server도 정상적으로 실행되었다.

👉Topic 만들기

./bin/windows/kafka-topics.bat --bootstrap-server localhost:9092 --list

명령어는 현재 Topic 리스트를 보여주는 것인데 현재 우리는 만든 Topic이 없어서 빈내용으로 종료되었다.

그 후

./bin/windows/kafka-topics.bat --bootstrap-server localhost:9092 --create --topic quickstart-events --partitions 1

Topic을 quickstart-events라는 이름으로 만들며 partition은 1로 나누어 생성한다는 의미의 명령어이다. 정상적으로 실행되면 화면과 같이 Created topic이 출력된다.

그 후 다시 list 명령어를 주면 빈칸이 아닌 topic을 출력하고

./bin/windows/kafka-topics.bat --bootstrap-server localhost:9092 --describe --topic quickstart-events

list대신 describe 옵션을 주면

topic의 상세 내용을 확인할 수 있다.

👉Producer, Consumer 사용하기

./bin/windows/kafka-console-producer.bat --broker-list localhost:9092 --topic quickstart-events

하나의 명령창에서 다음과 같이 Producer를 실행하며 topic은 quickstart-events로 지정한다.

./bin/windows/kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic quickstart-events --from-beginning

또 다른 명령창에서는 Consumer에 실행하고 마찬가지로 topic은 quickstart-events로 지정한다.

그럼 다음과 같은 명령창들이 실행되고 있으며

다음과 같이 Producer에서 입력되는 내용들이 그대로 Consumer에 전달되는 것을 확인할 수 있다.

새로운 Consumer를 위의 명령어로 실행하면

--from-beginning의 옵션으로 인해 똑같은 텍스트가 그대로 전달된것을 확인할 수 있다.