Skip to content
This repository has been archived by the owner on Oct 23, 2023. It is now read-only.

Add Akka Stream Producer Sink

Compare
Choose a tag to compare
@markglh markglh released this 02 Feb 11:14
· 12 commits to master since this release

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