Hello, Before I explain my question I want to say I tried looking for a problem previously explored which relates to mine but didn't find anything. If I am mistaken please excuse me and if possible provide me with a link to the right thread :)
I'm new to Akka Streams and am currently exploring the possibilities of integrating it's great capabilities when interacting with a queuing service as ones mentioned in the title. My use case with Akka Streams is to be able construct a source from an incoming message from the queue that I am subscribed to/am polling. Having went through the Akka docs, on the *Integration* page I found the sending emails to tweet's authors example come closest to my problem. We start with the tweet stream of authors: 1. val authors: Source[Author, Unit] = 2. tweets 3. .filter(_.hashtags.contains(akka)) 4. .map(_.author) It is unclear to me how these *tweets* come about? Furthermore after examining the Source object's apply methods I want to know: 1. Should a Source be created every time a new object is deserialized from a particular queue? 2. A Kafka consumer that I looked at extends ActorPublisher? Does that mean that if I have to wrap an actor around the client for the specific queue in order to be able to create a source from that? Thank you, Alex -- >>>>>>>>>> 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 [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
