Event-Driven Architecture Live
Welcome
Explore a complete Change Data Capture (CDC) pipeline running on Red Hat OpenShift with Streams for Apache Kafka, Debezium, Apache Camel, SonataFlow, and Apicurio Registry.
What You’ll Learn
-
Desplegar un cluster Kafka en modo KRaft (sin Zookeeper) usando AMQ Streams
-
Configurar Debezium para capturar cambios en PostgreSQL en tiempo real
-
Usar Apicurio Registry como Schema Registry para validación de eventos
-
Diseñar rutas de integración visualmente con Kaoto dentro de DevSpaces
-
Monitorear el pipeline con Grafana dashboards y Service Mesh (Kiali)
-
Gestionar Kafka desde Developer Hub con el plugin de Kafka
-
Usar Lightspeed (MCP) para troubleshooting del pipeline
Componentes del Pipeline
| Componente | Qué es | Para qué sirve en este demo |
|---|---|---|
Streams for Apache Kafka |
Distribución enterprise de Apache Kafka (basada en Strimzi) para streaming distribuido de eventos |
Cluster KRaft de 3 brokers que almacena y distribuye los eventos CDC con replicación, topics, bridge HTTP y exporter de métricas |
Debezium |
Plataforma open source de Change Data Capture (CDC) que captura cambios de bases de datos |
Conector PostgreSQL que lee el WAL y publica cada INSERT/UPDATE/DELETE como evento en topics Kafka en tiempo real |
Apicurio Registry |
Schema Registry open source que gestiona y valida esquemas de datos (Avro, JSON Schema, Protobuf) |
Registra y versiona los esquemas de los eventos CDC, garantizando compatibilidad entre productores y consumidores |
Apache Camel + Kaoto |
Framework de integración que implementa Enterprise Integration Patterns, con diseñador visual low-code |
Consume eventos CDC de Kafka, aplica content-based routing, y envía notificaciones email via Mailpit |
SonataFlow |
Motor de workflows serverless (evolución de Kogito/jBPM) que ejecuta procesos de negocio cloud-native |
Orquesta el onboarding de clientes: validación, clasificación, aprobaciones con SLA y provisión en paralelo |
Red Hat Developer Hub |
Portal de desarrollo self-service basado en Backstage, con catálogo de componentes y plugins |
Plugin de Kafka para visualizar offsets y lag de consumer groups directamente en las entity pages |
Grafana + Service Mesh |
Stack de observabilidad: dashboards de métricas (Grafana), mTLS automático y traffic visualization (Kiali) |
Dashboard "Kafka CDC Pipeline" con throughput, lag y latencia; Istio ambient mode para mTLS sin sidecars |
OpenShift DevSpaces |
IDE cloud-native basado en Eclipse Che, con workspaces efímeros y extensiones pre-configuradas |
Workspace con Kaoto pre-instalado para diseñar visualmente rutas Apache Camel y workflows SonataFlow |
OpenShift Lightspeed |
Asistente IA integrado en la consola de OpenShift con herramientas MCP para diagnóstico |
55+ herramientas MCP para troubleshooting del pipeline: consultar estado de Kafka, Debezium, connectors y pods |
Keycloak |
Identity and Access Management (IAM) enterprise basado en estándares OAuth 2.0 / OIDC |
Autenticación SSO para todos los servicios del demo (Console, Developer Hub, Grafana, etc.) |
Acceso al entorno
-
Kafka Console:
https://kafka-console-kafka-cdc.apps.cluster-l9nhj.dynamic.redhatworkshops.io -
Apicurio Registry:
https://apicurio-registry-kafka-cdc.apps.cluster-l9nhj.dynamic.redhatworkshops.io -
Kafka Bridge (REST):
https://kafka-bridge-kafka-cdc.apps.cluster-l9nhj.dynamic.redhatworkshops.io -
Grafana:
https://grafana-observability.apps.cluster-l9nhj.dynamic.redhatworkshops.io -
Developer Hub:
https://backstage-developer-hub-developer-hub.apps.cluster-l9nhj.dynamic.redhatworkshops.io -
DevSpaces (Kaoto):
https://devspaces.apps.cluster-l9nhj.dynamic.redhatworkshops.io
Suscripciones Red Hat requeridas
| Producto / Suscripción | Documentación |
|---|---|
Red Hat OpenShift Container Platform |
|
Red Hat Streams for Apache Kafka |
|
Red Hat build of Debezium |
|
Red Hat build of Apicurio Registry |
|
Red Hat build of Apache Camel |
|
Red Hat Developer Hub |
|
Red Hat OpenShift Dev Spaces |
|
Red Hat OpenShift Service Mesh |
|
Red Hat OpenShift Lightspeed |
|
Red Hat OpenShift Serverless Logic |
|
Red Hat build of Keycloak |
|
Red Hat OpenShift GitOps |
|
Red Hat OpenShift Pipelines |
|
Red Hat OpenShift Serverless |
|
Cluster Observability Operator |
|
Red Hat OpenShift distributed tracing |
|
Grafana Operator |