5.2.3 • Published 1 year ago
@epsor/kafka-producer v5.2.3
@epsor/kafka-producer
The is the packet which has the responsability to encode/decode mesages for/to the event store.
Usage
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();
}
})();
5.2.3
1 year ago
5.2.2
1 year ago
5.2.1
1 year ago
5.2.0
1 year ago
5.1.1
2 years ago
5.1.0
2 years ago
5.0.0
2 years ago
4.1.0
2 years ago
4.0.0
4 years ago
3.1.3
4 years ago
3.1.2
4 years ago
3.1.1
5 years ago
3.1.0
5 years ago
3.0.0
5 years ago
2.1.1
5 years ago
2.1.0
5 years ago
2.0.5
5 years ago
2.0.4
5 years ago
2.0.3
5 years ago
2.0.2
5 years ago
2.0.0
5 years ago