728x90
현재 개발 중인 프로젝트는 이벤트 기반 아키텍처로 각 서비스는 이벤트를 발행/구독 형식으로 구성된다. 하지만 모든 서비스는 독립적인 서버로 실행되고 있기 때문에 이벤트를 수신하는 방식에 대해서 고민을 해야 한다. 그중 요즘 다들 사용한다는 kafka를 이용하는데 kafka client 중 nest.js 기본 client인 kafka.js에 대한 이야기다.
일단 kafka.js는 주인장이 손을 놓고 다음 주인장을 애타게 찾고 있는 프로젝트로 Nest.js에서 기본으로 구성된 kafaka를 사용한다면 이 녀석을 사용할텐데, 만약 kafka 메시지가 lz4로 압축된 경우 문제가 발생한다. kafka.js는 압축 방식을 몇 가지 제공해 주는데 그중 실제로 구현된 압축 방식은 gzip만 제공되기 때문에 그 외 압축 방식은 plugin을 추가로 설치하던지 직접 구현해야 한다.