No More Silos: Integrating Databases and Apache Kafka
summary
Shows concrete integrations: uses Kafka Connect (JDBC source and binlog connectors) to stream MySQL into Kafka, demonstrates a snapshot then continuous capture, and runs a live join with ksql to enrich incoming rating events with customer data. Compares query-based CDC (simple polling, misses deletes and intermediate updates, adds DB load) with log-based CDC (binlog captures before/after, insert/update/delete), uses Schema Registry and Avro/Protobuf for schemas, and the demos work end-to-end.
AI-written summary · about
chapters (12)
- 0:00Introduction
- 1:25Why use Apache Kafka
- 4:34Streams of data
- 5:20Events
- 14:08Change Data Capture
- 15:25Transaction Log
- 15:44What is Transaction Log
- 23:58Querybased Capture
- 30:37Sequel
- 37:25Why PreService
- 38:25Try it out
- 38:38References
related talks
53mApache Kafka and KSQL in Action : Lets Build a Streaming Data Pipeline!
43mApache Kafka and KSQL in Action: Let’s Build a Streaming Data Pipeline!
02h 03mBuild CDC pipeline using Kafka ecosystem
39mKafka as a Platform: The Ecosystem from the Ground Up
42mFrom zero to hero with Apache Kafka's connect API
01h 07mKafka Streams and KSQLDB
26mConnecting distributed data with Apache Kafka
45mFrom Zero to Hero with Kafka Connect
