Thanks for your answer. I'm currently in the middle of something and
haven't had the opportunity to check this out. I'll have a look into your
suggestion ASAP, but it seems it could be the way to go. I'll update this
thread as soon as I test the solution. Thanks!.
BR,
Juanjo.
El lunes, 1 de
Hi Huan,
What you need is a back-channel from the Cassandra Sink to the Kafka
Source. In Akka Streams the way to solve this is to create an explicit
backward channel with streams.
For example if you have an async Kafka API that gives back the result of
your read as a Future, together with some
Hello everyone,
I'm starting with Akka Streams and so far everything is going well.
However, I have met with a use case that I don't know how to approach. The
scenario is a stream with an ActorPublisher as a source that is consuming
messages from Kafka and a subscriber as a sink that updates a
