Expand description
§Change Data Capture (CDC) Stream Processor
Advanced CDC capabilities for streaming database changes, event sourcing, and real-time data integration with full support for inserts, updates, deletes, and schema evolution.
§Features
- Multiple CDC patterns (Debezium, Maxwell, Canal compatibility)
- Transaction boundary detection
- Schema evolution tracking
- Snapshot + incremental sync
- Deduplication and idempotency
- Backpressure handling for large transactions
- Metrics and monitoring
Structs§
- CdcConfig
- CDC processor configuration
- CdcEvent
- CDC event representing a database change
- CdcEvent
Builder - CDC event builder for convenient event construction
- CdcMetrics
- CDC processing metrics
- CdcProcessor
- CDC processor with transaction handling and deduplication
- CdcSource
- CDC source identifier
Enums§
- CdcConnector
- CDC connector types
- CdcOperation
- CDC operation types following industry standards