| Interface | Description |
|---|---|
| CdcTimestampExtractor |
Interface defining the contract for CDC timestamp extraction.
|
| Class | Description |
|---|---|
| CdcDebeziumTimestampExtractor |
Timestamp extractor for Cdc debezium deserialization.
|
| CdcWatermarkStrategy |
Watermark strategy for CDC sources, generating watermarks based on timestamps extracted from
records.
|
| MessageQueueCdcTimestampExtractor |
Timestamp extractor for Kafka/Pulsar sources in CDC applications.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.