Skip to content

Este es un microservicio en NestJS que funciona como consumidor de un tópico de Kafka. Su objetivo es procesar mensajes y llevar a cabo acciones en función de la información recibida

License

Notifications You must be signed in to change notification settings

Antonio-112/kafka-connection

Repository files navigation

Microservicio de NestJS destinado la integracion de kafka

Este repositorio contiene un microservicio desarrollado con NestJS que se conecta a Kafka para consumir mensajes en tiempo real. Este servicio puede ser utilizado para integrar diferentes sistemas que lo requieran y mantener un seguimiento de los cambios que ocurren en tu sistema a través de Kafka.

Requerimientos

Para utilizar este microservicio es necesario contar con NodeJS y NestJS instalados. Además, se debe contar con acceso a un cluster de Kafka y configurar adecuadamente las variables de entorno.

Instalación

  1. Clonar este repositorio en tu máquina local.
  2. Ejecutar el comando npm install para instalar las dependencias.
  3. Configurar las variables de entorno en el archivo .env, utilizando el archivo .env.example como referencia.
  4. Ejecutar el comando npm start para iniciar el microservicio.

Pruebas

Para ejecutar los tests del microservicio, utiliza el siguiente comando:

npm run test

Este comando ejecutará los tests unitarios y de integración, utilizando Jest como framework de pruebas.

Recuerda que para ejecutar los tests es necesario tener un cluster de Kafka disponible para realizar las pruebas de integración. Puedes configurar las variables de entorno para utilizar un cluster de Kafka en un ambiente de desarrollo o pruebas.

Uso

Antes de iniciar el microservicio, asegúrate de tener un cluster de Kafka disponible. Si no tienes uno disponible, puedes utilizar Docker Compose para iniciar un cluster de Kafka localmente:

docker-compose up -d

Este comando iniciará un cluster de Kafka en Docker, el cual puedes utilizar para pruebas o desarrollo.

Una vez iniciado el cluster de Kafka, puedes iniciar el microservicio con el siguiente comando:

npm start

Recuerda detener el cluster de Kafka de Docker Compose cuando termines de utilizarlo:

docker-compose down

Contribuciones

Si deseas contribuir a este proyecto, por favor sigue los siguientes pasos:

  1. Haz un fork de este repositorio.
  2. Crea una rama con tu nueva funcionalidad o arreglo.
  3. Realiza tus cambios y verifica que todo funciona correctamente.
  4. Realiza una solicitud de extracción a la rama principal de este repositorio.

Licencia

Este proyecto está bajo la Licencia MIT - ver el archivo LICENSE para más detalles.

About

Este es un microservicio en NestJS que funciona como consumidor de un tópico de Kafka. Su objetivo es procesar mensajes y llevar a cabo acciones en función de la información recibida

Topics

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published