The GitHub Actions job "Check License" on fluss.git/producer has succeeded.
Run started by GitHub user platinumhamburg (triggered by platinumhamburg).

Head commit for run:
efb2ffedd822988ba04276af0ca0e27a306b0ef2 / ocean.wy <[email protected]>
[FLUSS] Add Producer Offset Snapshot for Exactly-Once semantics

Core changes:
- Add ProducerSnapshotManager for lifecycle management with atomic registration
- Add ProducerSnapshotStore for ZK + remote storage operations
- Add tryRegisterProducerSnapshot in ZooKeeperClient for atomic check-and-create
- Add Admin API: registerProducerOffsets, getProducerOffsets, 
deleteProducerOffsets
- Add configurable TTL and cleanup interval for producer snapshots

Design highlights:
- Atomic registration via ZK's NodeExistsException handling
- Eventually consistent: ZK as commit point, orphan files cleaned periodically
- UUID-based file naming prevents concurrent upload conflicts

Tests:
- ProducerSnapshotManagerTest: lifecycle, expiration, concurrent atomicity
- ProducerSnapshotJsonSerdeTest: JSON format compatibility

Report URL: https://github.com/apache/fluss/actions/runs/21234429186

With regards,
GitHub Actions via GitBox

Reply via email to