해당 코드들로 간단하게 Kafka server 동작을 확인할 수 있다.
kafkaHost에 address(domain name)와 port를 수정한 후 node를 통해 해당 코드를 돌려보면 된다.

package install

npm install kafka-node

producer.js

const {Producer, KafkaClient} = require('kafka-node');
const client = new KafkaClient({'kafkaHost':'address:port'});
const producer = new Producer(client);
const payloads = [
  {topic: 'topic1', messages: 'this is topic1'},
  {topic: 'topic2', messages: ['this is', 'topic2']}
];
producer.on('ready', () => producer.send(payloads, (err, data) => console.log(err, data)));
producer.on('error', err => console.log(err));

consumer.js

const {Consumer, KafkaClient} = require('kafka-node');
const client = new KafkaClient({'kafkaHost':'address:port'});
const payloads = [
  {topic: 'topic2'}
];
const consumer = new Consumer(client, payloads);
consumer.on('message', message=>console.log(message));
consumer.on('error', err=>console.log(err));