Thanks Konrad. I'll test it out more..
On Wednesday, January 31, 2018 at 8:22:00 PM UTC-5, Konrad Malawski wrote:
>
> There is no reliable way to know what “everything is done” means.
> This is because operations are asynchronous, and if you were to observe
> “oh! nothing is in any mailbox!” the
There is no reliable way to know what “everything is done” means.
This is because operations are asynchronous, and if you were to observe
“oh! nothing is in any mailbox!” the next millisecond something may
actually be in the mailbox, because it was just being asynchonously added.
Shutting down the
Hi, Akka newbie here, I try the sample on Akka web site and notice the
ActorSystem still runs after the Actors have finished, and I have to hit
Enter to quit. Is there a way to shut down ActorSystem object once
everything is done? I already tried the suggestion to override the
reference.conf fi
never mind, it's not needed, I had communication with Spark in mind and
that does not require to be in same process.
On Wednesday, January 31, 2018 at 12:45:53 PM UTC-5, Philippe Derome wrote:
>
> Jeremy,
>
> do you have any intent to make this project available with Scala 2.11?
>
> Phil
>
>
> O
Jeremy,
do you have any intent to make this project available with Scala 2.11?
Phil
On Tuesday, January 30, 2018 at 5:21:52 PM UTC-5, Jeremy Townson wrote:
>
> Thanks for reporting this, Philippe. For anybody who experienced this
> problem, fixed in
> https://bitbucket.org/jtownson/swakka/co
Hello there,
Was wondering if anybody has a suggestion how to filter messages from a
committable kafka source while not loosing the committable offsets that
needs to be committed after it was sent to a sink.
Currently I'm reading from Kafka, filter and write the result to another
kafka topic u
Thanks for the answers @Tel Pressman and @Johannes Rudolph. I will try
these approaches and write it here if they work. Thanks again.
On Thursday, January 25, 2018 at 10:03:07 PM UTC+5:30, Johannes Rudolph
wrote:
>
> Hi,
>
> in akka-stream, processing is usually run in a fused fashion, i.e. with