Usando a Kafka
Para ejecutar Apache Kafka localmente usaremos tres contenedores (Kafka, Zookeeper, Kafdrop) organizados dentro de un archivo llamado “docker Compose”.
Después de iniciar los contenedores, espere unos minutos y use cualquier herramienta compatible con Apache Kafka para conectarse mediante el puerto tcp 29092. Para facilitar las pruebas en el entorno de desarrollo, este archivo de docker Compose viene con la herramienta Kafdrop.
Siga los pasos a continuación para comenzar con Kafka:
- Clonar el repositorio
git clone https://github.com/devprime/kafka
- Para empezar
docker-compose up -d
- Enumere los tres contenedores activos
docker ps
- Para terminar
docker-compose down
Empezando a configurar temas en Kafka
Los microservicios basados en DevPrime se conectan automáticamente a servicios de transmisión como Kafka y, en los ejemplos, usamos algunos temas estándar como orderevents y paymentevents.
- Abra Kafdrop en el navegador en http://localhost:9000
- Vaya a la opción “Tema” y Nuevo agregando “orderevents” y luego “paymentevents”
- Revisa los temas creados
Visualización de mensajes en Kafka
Al utilizar el microservicio, enviaremos eventos a través de Kafka y los visualizaremos a través de la herramienta Kafdrop haciendo clic en el tema y luego en “Ver mensajes”.