Event-Driven Architecture Live

Red Hat OpenShift

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.)

Suscripciones Red Hat requeridas

Producto / Suscripción Documentación

Red Hat OpenShift Container Platform

OpenShift Container Platform 4.20

Red Hat Streams for Apache Kafka

Streams for Apache Kafka

Red Hat build of Debezium

Red Hat build of Debezium

Red Hat build of Apicurio Registry

Apicurio Registry

Red Hat build of Apache Camel

Apache Camel

Red Hat Developer Hub

Developer Hub

Red Hat OpenShift Dev Spaces

OpenShift Dev Spaces

Red Hat OpenShift Service Mesh

OpenShift Service Mesh

Red Hat OpenShift Lightspeed

OpenShift Lightspeed

Red Hat OpenShift Serverless Logic

OpenShift Serverless

Red Hat build of Keycloak

Red Hat build of Keycloak

Red Hat OpenShift GitOps

OpenShift GitOps (ArgoCD)

Red Hat OpenShift Pipelines

OpenShift Pipelines (Tekton)

Red Hat OpenShift Serverless

OpenShift Serverless (Knative)

Cluster Observability Operator

Cluster Observability Operator

Red Hat OpenShift distributed tracing

OpenShift distributed tracing (OpenTelemetry)

Grafana Operator

Grafana via Cluster Observability