Hi guys,
I'm trying to work out the following problem. Let me first describe the
scenario. I have an actor that loops over a specific set of numbers.
val someActor = system.actorOf(Props(new Actor {
var i = 1
def receive = {
case x: Int =>
log.info("Actor message is: " +
Hello,
I have an application that reads events from a Kafka queue and based on the
content calls an API endpoint.
Here is the relevant part of the class that creates the stream:
private def createFlowsFor(consumer: Publisher[StringKafkaMessage]) =
Source(consumer)
.map(_.message())
.map(Ru
Hi,
I've been working on a service that connects to a tool called GNIP that
streams tweets through a TCP connection. I have two services that
independently connect to GNIP and yesterday both of them went
simultaneously down. I checked nestat and saw that the tcp connection was
gone which made
Hello,
I'm uncertain whether this is the correct place for my question since it
falls in the middle between Akka Streams, Slick 3.0 and Futures in Scala
but I will give it a shot. Please excuse me if you think otherwise.
First about the scenario. I have a flow whose purpose is to create some
a
Hi Konrad,
Thanks for the reply!
You're right that we should explain what it is on the integrations page
> (would you like to submit a PR to help us with that? a :ref: link to the
> quickstart would help I think).
>
Of course, I'd like to help. Are these docs stored in the akka/akka github
re
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 explorin