hermesjs-kafka

Kafka adapter for HermesJS.

Installing

npm install hermesjs-kafka

Example

const Hermes = require('hermesjs');
const KafkaAdapter = require('hermesjs-kafka');

const app = new Hermes();

app.addAdapter(KafkaAdapter, {
  clientId: 'myClientId',
  brokers: ['localhost:9092'],
  consumerOptions: {
    groupId: 'myGroupId',
  },
  topics: ['user__signedup'],
  topicSeparator: '__',
});

See a working example here.

Author

Fran Méndez (fmvilas.com)