- NestJS์ Kafka๋ฅผ ์ฌ์ฉํ์ฌ ์ค์๊ฐ ๋ง์ดํฌ๋ก์๋น์ค ์ํคํ ์ฒ๋ฅผ ๊ตฌ์ถํฉ๋๋ค. ๐๏ธ
- API ๊ฒ์ดํธ์จ์ด๋ ํด๋ผ์ด์ธํธ ์์ฒญ์ ๋ฐ์ Kafka ํ ํฝ์ ๋ฉ์์ง๋ฅผ ๋ฐํํฉ๋๋ค. ๐ช
@nestjs/microservices
๋ฅผ ์ฌ์ฉํ์ฌ NestJS ์ ํ๋ฆฌ์ผ์ด์ ์ Kafka ๋ง์ดํฌ๋ก์๋น์ค๋ก ๊ตฌ์ฑํฉ๋๋ค. โ๏ธnpm check updates
๋ฅผ ์ฌ์ฉํ์ฌ NestJS ๋ผ์ด๋ธ๋ฌ๋ฆฌ๋ฅผ ์ต์ ๋ฒ์ ์ผ๋ก ์ ๊ทธ๋ ์ด๋ํฉ๋๋ค. โฌ๏ธ- Docker Compose๋ฅผ ์ฌ์ฉํ์ฌ Kafka ๋ธ๋ก์ปค๋ฅผ ์ค์ ํ๊ณ ๊ด๋ฆฌํฉ๋๋ค. ๐ณ
@MessagePattern
๋ฐ์ฝ๋ ์ดํฐ๋ฅผ ์ฌ์ฉํ์ฌ ํน์ Kafka ํ ํฝ์ ๋ฉ์์ง๋ฅผ ์์ ํฉ๋๋ค. ๐- Kafka ์ปจ์๋จธ ๊ทธ๋ฃน ID๋ฅผ ์ค์ ํ์ฌ ๋ฉ์์ง ์ฒ๋ฆฌ ๋ฐฉ์์ ์ ์ดํฉ๋๋ค. ๐
@Inject
๋ฐ์ฝ๋ ์ดํฐ๋ฅผ ์ฌ์ฉํ์ฌ Kafka ํด๋ผ์ด์ธํธ๋ฅผ ์ปจํธ๋กค๋ฌ์ ์ฃผ์ ํฉ๋๋ค. ๐client.emit
์ ์ฌ์ฉํ์ฌ Kafka ํ ํฝ์ ๋ฉ์์ง๋ฅผ ๋ฐํํฉ๋๋ค. ๐ข- ๋ง์ดํฌ๋ก์๋น์ค ๊ฐ์ ํต์ ์ ์ํด Kafka๋ฅผ ์ฌ์ฉํ์ฌ ์ด๋ฒคํธ ๊ธฐ๋ฐ ์ํคํ ์ฒ๋ฅผ ๊ตฌํํฉ๋๋ค. ๐