Apache Kafka
Apache Kafka is a advanced techniques concept in the Data Engineering pillar.
Prerequisite Graph
View full graph →Apache Kafka is a advanced techniques concept in the Data Engineering pillar.
Analogy
Example
Find Gaps
Explain Apache Kafka as if teaching a colleague who is new to advanced techniques. Cover: what it is, how it works, and why it matters.
Create
Create a diagram that demonstrates Apache Kafka in a real-world advanced techniques scenario. Walk through your design decisions.
Show solution
A diagram for Apache Kafka should include: 1. The core components of apache kafka 2. How they interact 3. Expected outcomes or outputs
All 9 items
Streaming ETL for Suspicious Activity Reports: Real-Time AML Data Pipelines with Kafka and Flink
Architecture patterns for building real-time AML surveillance data pipelines using Apache Kafka for transaction ingestio
Terraform for Data Infrastructure: Infrastructure as Code for the Data Platform
Infrastructure as Code patterns for data platforms: Terraform modules for Kafka clusters, Iceberg catalogs, dbt Cloud pr
Kubernetes for Data Engineering: Running Data Pipelines on K8s
Running data workloads on Kubernetes: Airflow Executor types (Celery vs Kubernetes), Dagster on K8s, Spark on Kubernetes
Debezium and CDC: Capturing Database Changes at Scale
Change Data Capture with Debezium: connector configuration, schema evolution handling, initial snapshots, and integratio
Change Data Capture: Real-Time Sync Patterns and Tools
Change Data Capture (CDC) captures row-level changes in databases and streams them to downstream systems in real time. T
Schema Management: Registries, Evolution, and Migration Strategies
Schema management ensures data structures remain compatible across producers and consumers as systems evolve. This modul
Kreps, Narkhede & Rao (2011) - Kafka: A Distributed Messaging System for Log Processing
Kafka is a distributed publish-subscribe messaging system designed for high-throughput, fault-tolerant, persistent log p
Exactly-Once Semantics in Stream Processing
How Kafka + Flink/Spark achieve exactly-once processing: idempotent producers, transactional log offsets, and checkpoint