Comunicando dos microservicios usando Apache Kafka
Вставка
- Опубліковано 19 бер 2022
- Apache Kafka provee un sistema de mensajería mediante un bus de mensajes altamente escalable y resiliente. En entradas anteriores en nuestro blog hablamos sobre como instalar Kafka & Zookeeper desde Docker y sobre Windows directamente.
El código fuente del vídeo está disponible acá: github.com/yoandypv/spring-bo...
* Aprende más en nuestro blog: sacavix.com/
* Apóyanos en Patreon: / sacavix_tech
(Con tu apoyo en Patreon accedes a ventajas exclusivas como directos, preguntas y respuestas en el chat, respuestas a tus dudas y acceso a nuestro libro "Patrones para la implementación de una arquitectura basada en microservicios".
En esta entrada expondremos como desarrollar una aplicación que consta de dos microservicios y entre ellos se comunican usando Kafka mediante el paso de eventos, un intento bastante simplista pero real de comunicación basada en eventos.
El problema a resolver en este vídeo es : Implementar la sección de una plataforma basada en microservicios que gestiona clientes y bajo ciertas condiciones debe enviar notificaciones por email a los mismos.
Para esto vamos a implementar dos pequeños servicios «Customers» & «Notifications».
Customers recibe por API REST una notificación de creación de un cliente y posteriormente publica un mensaje de «CUSTOMER CREATED» en el bus de mensajes, el consumidor en esta arquitectura simplificada será Notifications, que recibe el mensaje y lo procesa de manera totalmente asíncrona y desacoplada.
Este vídeo forma parte de la serie "Guiado por eventos", que tiene como objetivo explicar como implementar una arquitectura event driven.
Para aprender más visita nuestro blog: sacavix.com.
#microservicios #kafka #events #springboot - Наука та технологія
Excelente video si porfavor sería muy bueno que hicieras una serie de Kafka profundizando sobre los conceptos con ejemplos prácticos puede ser reutilizando un mismo proyecto durante la serie gracias por el aporte.
Gracias por ser parte Runnyr
Excelente aporte @SaCAViX Tech!
Gracias totales...
Excelente , Gracias por ahondar en estos temas de microservicios y sus componentes doc , están muy escasos , gracias por el apoyo a la comunidad 👍
Me encantan tus videos, aprendo muchas cosas e impulsa a seguir más a fondo. Gracias!
descubrí de casualidad tu canal y ha sido de gran ayuda para refrescar conocimientos de kafka. Excelentes videos!!!! siga asi master ;)
Muchas gracias por tus videos!
Son excelentes!
Excelente video Ingeniero!!! Muchas gracias por el aporte a la comunidad ya suscripto a su canal
Muy Buen Video, estaba perdido con kafka me ayudaste un monton y esta muy bien explicado gracias!
Excelente contenido, muchas gracias por compartir, es de gran ayuda!
Genial!! video muy bien explicado! gracias por compartir tus conocimientos :)
Que continue la serie por favor!!!!
Hola, super tus videos. Se agradece. Seria bkn uno de kafka.
Hola Yoandy muchas gracias por las mieles que estás compartiendo, ejemplos sencillos y muy prácticos! 💪💪💪
Gracias por tu comentario 👍
excelente video, gracias por compartir los conocimientos!
Muy buena explicación. Gracias
Mas facil no se puede explicar. Buen video 👍🏼
Qué canal más bueno, me encanta!!!
Excelente tutorial, muy bien explicado. Ahora intentaré implementarlo en mi proyecto
Gracias !
muchas gracias hermano tus videos me ayudan muchisimo
Excelente explicación
Excelente video!
¡Gran video! :D muchas gracias por explicarlo de una manera genial
Excelente explicación!
Gracias ZonaCoder
Brillante, gracias por compartir el conocimiento. Me gustaría saber cómo abordar el problema de una aplicación, spring boot por ejemplo, que tiene configurado un autoscaling de su contenedor. Cómo asegurarse de que al escalar la aplicación no procese eventos repetidos?
Un saludo, y gracias nuevamente por el conocimiento
Excelente explicación, una pregunta talvez una explicación donde se tenga en un proyecto separado todo lo de kafka y y en los otros proyectos solo utilizar el jar algo cómo in Kafka útil
hola, cuando haces un tutorial sobre el testeo de la conexion de servicios y kafka, para pruebas unitarias y de QA. Excelente video
Muy bueno
Great Video!!!
Master, gracias por Tu contenido, me gustaria saber que es mejor Kafka como Iaas o kinesis de aws como saas? Me refiero a characteristics y costos, gracias TIO sacavix,
Genial la explicación. ¿Me podrías decir que tema de intellij usas ?
Buen video estiamdo, podrías hacer uno sobre mapstruct xfa.
Lo tendré en cuenta, lo he estado testeando un poco hace unos días , esta muy bueno !
Excelsior
Video de kafka!!!!
Excelente video, vas a llegar a implementar el patrón saga?
Hola David, si como parte de la serie un poco más adelante
¿Y el video de los conceptos sobre eventos?
Que buen video muy bien explicado, una duda, ¿Por qué recomiendas inyectar por constructor en vez de usar la anotación @Autowired?. De antemano muchas gracias Inge.
Hola Victor, yo lo uso para darme cuenta cuando necesito refactorizar (si tengo muchos parámetros en el constructor algo estoy haciendo mal), si usas inyección por atributos ni cuenta te das y las clases se vuelven monstruos de grandes. Una explicación más completa acá: reflectoring.io/constructor-injection/#:~:text=Constructor%20injection%20helps%20in%20creating,cannot%20alter%20its%20dependencies%20anymore.
@@SACAViXTech muchas gracias, saludos desde México
ACabo de terminar un proyecto en Spring boot, y no se puede negar que es muy robusto, poderoso, estructurado, super tipado (obvio es Java), pero es inevitable extrañar a nodeJs, este mismo ejemplo, lo he podido emular en nodeJs con un 60% menos de config y lineas de codigos, si alguien me llega leer, es mejor aprender primero SpringBoot luego NodeJs, el cambio es mas llevadero, igual excelente video! y OJO, me encanta SpringBoot, pero es muy "Burocratico" por ponerle algun adjetivo!
Hola Jesús, si Java es muy verboso, es cierto, excelente ! Gracias por tu comentario 👍
Super excelente video, tengo una duda, el consumer ya queda activo por siempre escuchando ese topic?
Hola Luis, si queda suscrito siempre. Gracias por comentar!
hola, consulto lo siguiente. Si envio un mensaje que es atendido por 5 microservicios y 2 de ellos no pueden realizar la operación, ¿cómo y que se se informa al productor? , ¿existe alguna estrategia alternativa para controlar situacion?. gracias y saludos
Hola, gracias por el Video, en el min 16:32 indicas que no es recomendable inyectar con @Autowired sino por constructor, aunque he usado poco Spring boot, se emplearlo de los 2 modos, pero me podrias indicar por favor, por que no es recomendable el @Autowired sino la inyeccion por constructor? saludos!
Básicamente haciendolo desde el constructor, permites mantener la inmutabilidad del objeto como "final" así como sobretodo el tema de que te permite ver cuando una clase tiene demasiadas dependencias (ya que si tienes un constructor con 10 inyecciones, el principio de responsabilidad única es un sintoma de que comienza a tambalearse y por tanto puede ser un buen punto para realizar un refactor). En cambio con @Autowired esto se difumina ya que al tenerlo como propiedades de clase, no nos paramos a pensar (al menos visualmente es menos impactante) si tiene 2 o 20 dependencias...
Saludos!
crack
Seria bueno ir viendo cada concepto por separado en vídeos que se desplayen bien los conceptos.
Profe en caso de que una ruta se consuma y los datos sean modificados, y posteriormente no se puede enviar un evento al bus por algun error. ? Es decir El evento jamas llego al bus, pero aún así fueron modificados los datos en la base de datos de la ruta.
Hola en ese caso el sistema que se encarga de publicar el cambio si falla esa publicación debe continuar reintentandolo hasta que se restablezca el bus, en una arquitecta basada en eventos muchas veces el bus se convierte en la fuente de la verdad y debe cuidarse su disponibilidad más que cualquier otra cosa.
cual es el theme del ide??
tendras un ejemplo usando 2 microservios usando kafka en docker?
Hola, no tengo, pero tengo Kafka con Docker si lo necesitas déjame saber y lo comparto
En el microservicio que consume los mensajes, es requerido u opcional agregar la configuracion de seguridad para que confie en una clase especifica?
Hola Favio, como viene por defecto si, capaz si nos ponemos a jugar con la config de kafka podamos deshabilitarlo, pero habría que revisar la doc, a ciencia cierta no he tocado esa parte nunca antes.
Buen video, tengo una duda, se puede relacionar una tabla de un microservicio con otro? Si es así me podrías orientar en como se hace?
Hola Geekz, en realidad si el diseño es correcto debería pasar que los microservicios tengan sus bases de datos independientes y que cada microservicio sea responsable de guardar los datos que necesita para evitar tener que hacer eso que planteas, aunque se repita alguna parte de la información. Debe implementarse un mecanismo de consistencia (eventual) que permita garantizar que los datos sean consistentes en todas las bases. Bus de mensajes + CQRS pueden ayudar a eso 💪
@@SACAViXTech Muchas gracias por tu respuesta🤙
Amigo tienes cursos en Udemy?
Hola Alex, disculpa la demora, no tengo en udemy no, andamos creando plataforma propia porque Udemy hace que tengamos que subir los precios y encarece tanto para estudiantes como la ganancia que deja al profesor. Pronto lanzamos y avisamos
Jum videos que no hay mucho en la red en español, preciso necesito estudiar esto para aplicarlo en la empresa
Hola Jum, gracias por tu comentario, que bueno que te sirva, igual no te quedes solo con esto, profundiza más que es inmenso el mundo kafka 😃
Viendo este ejemplo entiendo por que node js es muy solicitado actualmente para el desarrollo de microservicios, las forma de configuracion resulta mas facil y menos verboso que java.
Es cierto muchas startup arrancan por ahí que es más fácil, pero al final les pasa factura o tienen que ir a algo más escalable cómo Go o Java. Y si es cierto es menos verboso cómo dices, por suerte Kotlin vino al rescate 😊. Gracias por comentar.
@@SACAViXTech y por el motivo economico tambien me parece que es mas facil encontrar un desarrollador jac
vascript que acepte un sueldo bajo que en un programador java.
@@pablodariocerezogualancana9316 Cada uno aporta lo necesario para el desarrollo de sistemas que es el principal objetivo de los programadores.
Ufff que pereza ver tanto boilerplate code.. es lo típico que configuras una vez en un proyecto y luego haces copy paste siempre que lo necesites con pequeñas modificaciones jajaja
Hola! he probado el código, y si se escribe en un topic desde un proyecto con nombre diferente pero respetando clases (por ejemplo cambiando los nombres de los paquetes de este proyecto que escribe a "com.sacavixPrueba") el otro proyecto con el listener y esa configuración no lo leen, además de entrar en un bucle de errores que saltan por consola. El primero seria el de TRUSTED_PACKAGES" que una vez puesto a "*" para que acepte todos, sigue saltando un bucle de error por consola mencionando esta vez que la clase no existe, en este ejemplo seria asi:
Caused by: org.springframework.messaging.converter.MessageConversionException: failed to resolve class name. Class not found [com.sacavixPrueba.events.RequestCreatedEvent]; nested exception is java.lang.ClassNotFoundException: com.sacavixPrueba.events.RequestCreatedEvent
claro esta, mi proyecto que escucha tiene la mism a configuración que este pero estando la clase en com.sacavix.events.RequestCreatedEvent y no en com.sacavixPrueba.events.RequestCreatedEvent
Es decir, unicamente se escuchan si proceden de un proyecto con los mismos paquetes y nombres de las clases igual, no estando esto de forma correcta.
Un saludo y espero respuesta!!
Otra cuestión es que en la linea 30 de KafkaConsumerConfig.java pone JsonSerializer, ¿No debería ser JsonDeserializer)
Hola Jesus, gracias por comentar, pudiste resolver por fin este tema ? Las veces que lo he usado en realidad nunca he cambiado el classpath de casualidad, recuerdo solo que con redis me paso lo mismo en una ocasión, dime sino lo resolvistes y tiro unas pruebas y te ayudo a resolverlo. Gracias ! (perdona la demora en la respuesta)