Exactly-Once Processing Semantics #68
Description
- Checkpointing & State Snapshots: Provide a mechanism for periodic state snapshots and checkpoints to recover from failures without data loss or duplication.
- Idempotent/Transactional Sinks: Integrate with sinks that support transactions (e.g., Kafka transactional producers, SQL databases with transactional semantics) to ensure exactly-once delivery.