Este paquete contiene varios adaptadores útiles
Para instalar el paquete, usa npm:
npm install @quo-digital/adapters kafkajs dotenv
- ✔ Adaptador para Kafka usando
kafkajs
- ✔ Adaptador para AWS S3 usando
aws-sdk/client-s3
- ✔ Adaptador para HttpService de
@nestjs/axios
- ✔ Adaptador para
xlsx
- ✔ Adaptador para csv usando
csv-parse
- KAFKA_HOST
- KAFKA_PORT
- KAFKA_CLIENT_ID
- S3_PUBLIC_KEY
- S3_SECRET_KEY
- S3_ENDPOINT
- S3_REGION
// Creación de un productor de Kafka
const kafkaProducer = new KafkaProducer(kafkaAdapter);
// Envío de un mensaje
kafkaProducer.send({
topic: 'my-topic',
messages: [
{ value: 'Hello Kafka' }
]
});