acked-stream
acked-stream copied to clipboard
Message Acknowledgement for Akka Streams
thought I might be able to do it quickly but it seems one has to understand how to reimplement it with the GraphStage.
Hi! I often find myself with the same dilemma of ack external systems, like Kafka/rabbit etc, and no one seems to talk about that in the streams docs/articles I read,...
I see there's a nacked message that extends exception. Curious if this implies that asynchronous operations resulting in a failed future would cause a nack? Alternatively is there any way...