Event-Driven Change Data Capture Pattern Using Apache Pulsar
summary
Shows a working CDC pipeline that reads Cassandra change logs, pushes events into Apache Pulsar via DataStax Astra Streaming, applies lightweight transformations with Pulsar Functions, and sinks records to targets like Elasticsearch using Pulsar connectors. Demo uses the Astra UI to create tenants, topics and producers so CDC topics appear automatically; storage is handled by BookKeeper and cluster metadata by ZooKeeper. Project growth even outpaces Kafka contributors as of 2021, and the demo components run end-to-end.
AI-written summary · about
chapters (11)
- 0:00Start
- 2:05Agenda
- 11:28Log Based Cdc
- 12:56Requirements for a Modern Uh Cdc System
- 14:0412 Factor Guidelines
- 15:28Scalability
- 21:31What Is Pulsar
- 28:54Components of Pulsar 2
- 29:16Components of Pulsar
- 30:28Zookeeper
- 35:15Enabling Cdc
related talks
36mEvent-Driven Change Data Capture pattern
48mApache Pulsar: Event Streaming in The Cloud Native World
34mEvent Streaming in the Cloud Native World with Apache Pulsar
55mEvent Messaging and Streaming with Apache Pulsar
51mEvent Streaming and Processing with Apache Pulsar
59mEvent Streaming and Processing Using Apache Pulsar
30mChange Data Streaming Patterns in Distributed Systems
35mStreaming Data Made Easy
