I was originally imagining a long flow from a akka-streams-kafka commitableSource, but due to the issue I raised earlier about needing CommitableMessages throughout the flow, I am considering splitting the stream in StreamA and StreamB, where StreamA would capture the consumed messages in a persistent actor. This means I need a way to forward the received messages to StreamB.
I get the impression that Sink.actorRefWithAck is favored over ActorSubscriber, and Source.queue is favored over ActorPublisher. Should Actor B (which runs StreamB) just use eventsByTag to get its Source? Or would performance be better if the persistent actor implemented AtLeastOnceDelivery to send the message to ActorB which would offer it to a SourceQueue it held internally? Thanks. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
