kafka 글을 작성하기 전에

회사에서는 RabbitMQ를 사용하고 있습니다.

 

개발자로 일을 시작한지 5달정도가 되었고, 코딩을 시작한지 1.5년정도가 되었기 때문에 회사에서 일을 하기 전까지는 RabbitMQ, Kafka 등에 대해 들어본적 이없었습니다.

단순히 부트캠프를 할 때, 간간히 카카오 현업 코치님께서 하시는 말씀 중 kafka라는 단어가 있어 머릿속에 놓여있을 뿐이였죠.

 

그런데 회사에서 제가 RabbitMQ consumer app을 리팩토링을 해볼 기회가 생겼고, 리팩토링 하며 RabbitMQ가 어떤 것인지 알게 되었습니다. 그리고 NestJS 카카오톡 오픈 채팅방에서 어떤 분께서 본인이 pub/sub pattern과 여러 기술 스택을 사용하여 토이프로젝트를 진행하는데, 도와주실 분이 없냐는 말씀을 하셨습니다. 그것을 보고 pub/sub pattern과 회사에서 다뤄보지 않은 kafka에 대해서도 흥미가 생겼습니다.

 

pub/sub pattern에 대한 개념은 인터넷에 다른분들이 자세하게 설명을 해주셔서 검색해보시면 될것같습니다.

또한, 일단은 메인 주제가 Kafka이기 때문에 RabbitMQ도 다른분들 설명으로 대체하겠습니다.

RabbitMQ 동작 이해하기: https://velog.io/@chss3339/RabbitMQ-동작-이해하기

Node.js의 RabbitMQ client 라이브러리 기본 셋팅: https://velog.io/@chss3339/amqplib-셋팅

 

저는 Node.js를 사용하는 백엔드 개발자 이기때문에, kafkajs를 사용하여 셋팅하는 방법과 설명을 작성하려고 합니다.

공식문서를 보면 다 나오고 저도 공식문서를 보고 공부했지만, 공식문서가 익숙하지 않은 분들이 계실수도 있고 부가적인 설명을 곁들인다면 더 이해가 잘 되실것이라고 생각합니다.