Event-Driven Architecture Live

Streams for Apache Kafka

Enterprise distribution of Apache Kafka (Strimzi-based) for distributed event streaming

KRaft cluster with 3 brokers that stores and distributes CDC events with replication, topics, HTTP bridge, and metrics exporter

Debezium

Open source Change Data Capture (CDC) platform that captures database changes

PostgreSQL connector that reads the WAL and publishes each INSERT/UPDATE/DELETE as an event to Kafka topics in real time

Apicurio Registry

Open source Schema Registry that manages and validates data schemas (Avro, JSON Schema, Protobuf)

Registers and versions CDC event schemas, ensuring compatibility between producers and consumers

Apache Camel + Kaoto

Integration framework implementing Enterprise Integration Patterns, with a low-code visual designer

Consumes CDC events from Kafka, applies content-based routing, and sends email notifications via Mailpit

OpenShift Integration Operator

Community OperatorHub operator: Kaoto in the OpenShift console, ephemeral Quick Try, GitOps promote, MCP/AI

Installs in openshift-integration and adds Integration Platform so you create IntegrationFlow CRs without replacing the CDC Camel Deployment

SonataFlow

Serverless workflow engine (evolution of Kogito/jBPM) that runs cloud-native business processes

Orchestrates customer onboarding: validation, classification, approvals with SLA, and parallel provisioning

Red Hat Developer Hub

Self-service developer portal based on Backstage, with a component catalog and plugins

Kafka plugin to visualize consumer group offsets and lag directly on entity pages

Grafana + Service Mesh

Observability stack: metric dashboards (Grafana), automatic mTLS, and traffic visualization (Kiali)

"Kafka CDC Pipeline" dashboard with throughput, lag, and latency; Istio ambient mode for mTLS without sidecars

OpenShift DevSpaces

Cloud-native IDE based on Eclipse Che, with ephemeral workspaces and pre-configured extensions

Workspace with Kaoto pre-installed to visually design Apache Camel routes and SonataFlow workflows

OpenShift Lightspeed

AI assistant integrated into the OpenShift console with MCP tools for diagnostics

55+ MCP tools for pipeline troubleshooting: query Kafka, Debezium, connector, and pod status

Keycloak

Enterprise Identity and Access Management (IAM) based on OAuth 2.0 / OIDC standards

SSO authentication for all demo services (Console, Developer Hub, Grafana, etc.)

NeuroFace (Computer Vision)

Facial recognition application with LBPH + OpenVINO Model Server (face-detection-retail-0005)

Registers faces via webcam, detects people, and publishes events to the Kafka topic cv.face.detections

OpenVINO Model Server (OVMS)

Intel inference server deployed as a KServe InferenceService on OpenShift AI

Serves the face-detection-retail-0005 model (FP16) via REST/gRPC for face detection

CV Processor (Python)

Python microservice that polls OVMS and NeuroFace, producing and consuming Kafka events

Publishes person_registered and ovms_model_status events, sends email alerts via Mailpit