@studiowebux/pubsub NPM

Introduction

This module wraps KafkaJS commands

Installation

npm install --save @studiowebux/pubsub

NPM

Usage

Configuration

TL;DR; Same as kafkajs, they are split using a different approach but the rest is the same.

const config = {
  // Documentation: https://kafka.js.org/docs/configuration
  client: {
    clientId: 'my-app',
    brokers: ['localhost:9092'],
    logLevel: logLevel.DEBUG,
    logCreator,
  },
  // Documentation: https://kafka.js.org/docs/producing#options
  producer: { connect: {} },
  // Documentation: https://kafka.js.org/docs/consuming#options
  consumer: { connect: {}, subscribe: { fromBeginning: false } },
};