This repository has been archived by the owner on Oct 23, 2023. It is now read-only.
Add Akka Stream Producer Sink
Adds a KinesisSinkGraphStage that uses an underlying KinesisProducerActor to do the heavy lifting. The stream manages back pressure by allowing only a fixed number of outstanding messages. A materialized value is used to indicate, when a stream has been finished (or failed).
See: https://github.com/WW-Digital/reactive-kinesis#akka-stream-sink