프로젝트 Apache Kafka 에 통합 Node.js

Apache Kafka 프로젝트 에 통합하면 Node.js Kafka의 데이터 처리 기능을 활용하는 실시간 애플리케이션을 구축할 수 있습니다. Apache Kafka 다음은 프로젝트 에 통합하는 방법에 대한 기본 가이드입니다 Node.js.

1단계: Kafka 라이브러리 설치 Node.js

프로젝트 디렉토리 에서 터미널을 엽니다 Node.js.

다음 명령을 실행하여: 에 대한 라이브러리인 kafkajs 라이브러리를 설치합니다. Node.js Apache Kafka npm install kafkajs

2단계: Kafka와 상호 작용하는 코드 작성 Node.js

kafkajs 라이브러리를 코드로 가져옵니다 Node.js.

const { Kafka } = require('kafkajs');

다음에 대한 구성 매개변수 정의 Kafka Broker:

const kafka = new Kafka({  
  clientId: 'your-client-id',  
  brokers: ['broker1:port1', 'broker2:port2'], // Replace with actual addresses and ports  
});  

producer 메시지를 보낼 만들기:

const producer = kafka.producer();  
  
const sendMessage = async() => {  
  await producer.connect();  
  await producer.send({  
    topic: 'your-topic',  
    messages: [{ value: 'Hello Kafka!' }],  
  });  
  await producer.disconnect();  
};  
  
sendMessage();  

consumer 메시지를 수신하려면 다음을 작성하십시오 .

const consumer = kafka.consumer({ groupId: 'your-group-id' });  
  
const consumeMessages = async() => {  
  await consumer.connect();  
  await consumer.subscribe({ topic: 'your-topic', fromBeginning: true });  
  
  await consumer.run({  
    eachMessage: async({ topic, partition, message }) => {  
      console.log(`Received message: ${message.value}`);  
    },  
  });  
};  
  
consumeMessages();  

참고: 'your-client-id', 'broker1:port1', 'your-topic' 및 같은 값을 'your-group-id' 실제 프로젝트 정보로 바꾸십시오.

Apache Kafka 에 통합하는 것은 Node.js 특정 요구 사항에 따라 더 복잡할 수 있습니다. 구성 옵션 및 기능에 대한 자세한 내용은 공식 문서 Apache Kafka 및 라이브러리를 참조하십시오. kafkajs