@epsor/kafka-producer

@epsor/kafka-producer

The is the packet which has the responsability to encode/decode mesages for/to the event store.

Usage

• @epsor/kafka-producer
  • Produce a message

Produce a message

import producer from '@epsor/kafka-producer';
import uuid from 'uuid';

const message = {
  headers: {
    version: 'v1.0',
    type: 'user.created',
    uuid: uuid.v4(),
  },
  uuid: uuid.v4(),
  email: 'ok',
  firstname: 'Jean',
  lastname: 'Michel',
};

(async () => {
  try {
    await producer.produce(message, process.env.EVENT_TOPIC);
  } finally {
    await producer.disconnect();
  }
})();