728x90 반응형 Kafka3 [kafka] kafkajs 사용하여 producer / consumer 서버 만들기 (kafkajs) 간단하게 nodejs express를 통해 api 를 만들고 해당 api를 통해 producer -> kafka -> consumer로 전달되는 간단한 메시지 서버를 kafkajs를 이용해서 만들어 보겠습니다. 1. express 및 kafkajs 설치 npm 을 이용해서 express와 kafkajs를 설치합니다. $ npm install express $ npm install kafkajs 2. express 서버 구성 event 메시지를 받을 수 있는 간단한 api가 구현된 index.js 를 생성 합니다. const express = require('express') const app = express() const port = 3000 app.post('/events/:event', (req, .. 2022. 1. 25. [kafka] kafkajs 사용하여 producer / consumer 서버 만들기 (kafkajs) 간단하게 nodejs express를 통해 api 를 만들고 해당 api를 통해 producer -> kafka -> consumer로 전달되는 간단한 메시지 서버를 kafkajs를 이용해서 만들어 보겠습니다. 1. express 및 kafkajs 설치 npm 을 이용해서 express와 kafkajs를 설치합니다. $ npm install express $ npm install kafkajs 2. express 서버 구성 event 메시지를 받을 수 있는 간단한 api가 구현된 index.js 를 생성 합니다. const express = require('express') const app = express() const port = 3000 app.post('/events/:event', (req, .. 2022. 1. 25. [kfaka] kafka 시작해보기 kafka 를 통해서 간단히 events 쓰기 / 읽기를 구현해보고 node.js에서 해당 내용을 구현해보겠습니다. 1. kafka 설치 kafka 다운로드 및 설치 진행 $ tar -xzf kafka_2.13-3.0.0.tgz $ cd kafka_2.13-3.0.0 2. kafka 환경 구성 java 8+가 설치 되어 있어야 합니다. ZooKeeper 서비스를 실행 # Start the ZooKeeper service # Note: Soon, ZooKeeper will no longer be required by Apache Kafka. $ bin/zookeeper-server-start.sh config/zookeeper.properties 새로운 터미널에서 kafka broker service를 실.. 2022. 1. 24. 이전 1 다음 728x90 반응형