Build Real-Time CDC Pipelines on Alibaba Cloud EventBridge with DTS

Introduction

Change Data Capture (CDC) monitors upstream data changes and synchronizes them to downstream services for further processing. Event‑Driven Architecture (EDA) naturally fits CDC by treating data changes as events that services can listen to.

CDC Overview

CDC captures incremental data and schema changes from source databases and reliably streams them to target databases, data lakes, or analytics services. Popular open‑source CDC tools include Debezium, Canal, and Maxwell.

Alibaba Cloud Solution: DTS + EventBridge

Data Transmission Service (DTS) provides real‑time data flow across relational, NoSQL, and OLAP sources. EventBridge offers two event routing services: an Event Bus with persistence and an Event Stream for end‑to‑end streaming. EventBridge now supports DTS as a data‑subscription source, allowing seamless CDC integration.

Creating a DTS‑Based EventBridge Event Stream

Enable the EventBridge service.

Create a DTS data‑subscription task.

Create a consumer‑group account for consuming subscription data.

In the EventBridge console, select “Event Stream”, click “Create Event Stream”.

Provide a name and description.

Choose “Database DTS” as the event provider.

Select the previously created DTS subscription task and configure the consumer group, password, and initial consumption time.

Define event‑stream rules and targets, then save and start the stream.

Best‑Practice Scenarios

CQRS : Use EventBridge to capture DB changes via DTS, route them to Function Compute (FC), and update an Elasticsearch query model.

Microservice Decoupling : Capture order‑related DB changes, route events to RocketMQ, and let multiple consumer groups handle caching, finance, and logistics independently.

Database Backup & Heterogeneous Sync : Capture MySQL changes with DTS, use EventBridge to execute SQL on a target DB for backup, and forward events to Function Compute to sync to other databases.

Custom SQL Auditing : Capture changes with DTS, send events to Log Service (SLS), and query SLS for audit trails.

Technical Details

EventBridge’s DTS source connector pulls records from DTS, preserving fields such as id, operationType, topicPartition, beforeImage, and afterImage. It also adds system attributes required for streaming. Event ordering is guaranteed, but duplicate delivery may occur; use EventId for idempotent processing.

Conclusion

The article introduced CDC fundamentals, demonstrated how to apply CDC on EventBridge using DTS, and presented several practical use cases—from CQRS and microservice decoupling to backup, heterogeneous synchronization, and SQL auditing. As EventBridge expands its ecosystem across messaging, database, log, and big‑data services, it solidifies its role as a cloud‑native event hub.