Data First, SLA Always
Aug 1, 2019Johan Kok

Summary
Introduced Trailblazer, a Spark Structured Streaming application for Change Data Capture (CDC) from MySQL databases using Debezium and Kafka. This addresses the limitations of periodic batch ingestion and improves scalability for large tables by streaming binlogs in real-time to the data lake. Key design principles for Trailblazer include externally managed checkpoints (using Redis), handling varying data volumes through Spark configurations, using data as a health indicator, and treating streams as ephemeral. Monitoring strategies for these streams include tracking the running:active jobs ratio, microbatch runtime, and job liveliness.
More from the Data Lake Modernization with Apache Iceberg trail
- The Hugo evolution: Engineering Grab's unified, one-click data ingestion platform with Apache Flink
- Scaling Grab's Data Lake: Our journey to Apache Iceberg adoption
- Enabling near real-time data analytics on the data lake
- Rethinking Stream Processing: Data Exploration
- 2.3x faster using the Go plugin to replace Lua virtual machine