ZIO Streaming connector for Pravega
summary
Connector ports the Pravega Java API into ZIO/ZStream and implements ZIO resources management, layered accessors and finalizers, plus transactional stream writes and optimistic concurrent writes to a Pravega key‑value table. Demo writes ~1,000 events per language, shows sinks/readers, transactional writers, a websocket forwarder, retry policies and tests using shared ZIO layers and property testing. Claim: Pravega versioned updates plus ZIO retry and resource semantics make concurrent consistent updates practical and testable.
AI-written summary · about
chapters (7)
- 0:00Start
- 8:32Service Pattern - From Java to ZIO
- 9:38Service Pattern - ZLayer (Step 3)
- 11:59Service Pattern - Accessible (Step 4)
- 16:13ZIO-Pravega: Sink example
- 19:20ZIO-Pravega: Transactional Sink
- 25:26Conclusion && Roadmap
