Re: [akka-user] How do you use Flow.log() properly? ( http://doc.akka.io/japi/akka/current/akka/stream/javadsl/Flow.html#log-java.lang.String- )

Please post full examples when trying to debug such things ;-) I have to guess that you didn’t configure the actual logger. Yet you did configure the logging filter, so things will try to use the loggers config, but there is none, so empty. Works: http://github.com/ktoso/akka-logging-example — Ko

Re: [akka-user] How do you use Flow.log() properly? ( http://doc.akka.io/japi/akka/current/akka/stream/javadsl/Flow.html#log-java.lang.String- )

Yes, I have akka-slf4j_2.11-2.5.4.jar on my classpath. On Tuesday, September 19, 2017 at 8:34:02 PM UTC-7, Konrad Malawski wrote: > > Did you include the akka-slf4j bridge > https://www.google.com/search?q=akka-slf4j > as documented http://doc.akka.io/docs/akka/2.5.4/scala/logging.html ? > > — >

[akka-user] Akka Source - Continuous polling of database

Hi, I am new to Akka streams, I am currently trying to implement a Source that takes continuous input from RocksDB. The idea is to use RocksDB as a queue from which the source will constantly pull data, perform some stream operations and finally store it into a database store like Cassandra or

[akka-user] Parsing Akka Http Json Response

Hello, I'm new to the AKKA Http world. I have one of thing to accomodate in my code. Using *Routing*, I'm calling one of the API service to *complete *the response. Now, I want to parse this response before *complete *to send back to client (parsing and modification). Could someone help me, how

Re: [akka-user] How do you use Flow.log() properly? ( http://doc.akka.io/japi/akka/current/akka/stream/javadsl/Flow.html#log-java.lang.String- )

Did you include the akka-slf4j bridge https://www.google.com/search?q=akka-slf4j as documented http://doc.akka.io/docs/akka/2.5.4/scala/logging.html ? — Konrad `kto.so` Malawski Akka @ Lightbend On 20 September 2017 at 08:30:53, Bwmat (bwmat.reloa...@gmail.

[akka-user] Re: Question about how Akka streams handles exceptions

For some more context, the flow throwing the exception was the one returned by getRequestToResponseFlow() in the code shown in the question at https://groups.google.com/forum/#!topic/akka-user/MjwhVE8kIAI The SinkQueueWithCancel was connected to the sinkshape 'in_sink' which is passed to the bu

[akka-user] Question about how Akka streams handles exceptions

I'm doing a PoC in akka streams, and I just had to track down a case where the mapping functor in an instance of Flow.map() threw an exception. This seems to simply close the stream, but _not_ report it anywhere. Other stages were getting completed implicitly because of it, but the error didn't

[akka-user] seed node experienced high cpu usage which seems to have blocked cluster communication

Hi, We have a setup of an akka cluster with the following: seed node, a master node, and worker nodes. Workers will broadcast a request work message that the master node respond to. We deployed this setup in Google Kubernetes environment. It usually works fine. workers sometimes run out of memo

[akka-user] How do you use Flow.log() properly? ( http://doc.akka.io/japi/akka/current/akka/stream/javadsl/Flow.html#log-java.lang.String- )

I have the following code public static void main(String[] args) throws InterruptedException { final Config configuration = ConfigFactory.load(ConfigFactory. parseString( "akka {" + " loggers = [\"akka.event.slf4j.Slf4jLogger\"]\r\n" + "

[akka-user] Re: ArrayIndexOutOfBoundsException from call to akka.stream.javadsl.GraphDSL$Builder$ForwardOps.toInlet()

I fixed it by rewriting my stage to use FanInShape2 instead (must have been something wrong with my shape implementation), but now my graph seems to deadlock after a few stage operations. By putting breakpoints into my onPull() & onPush() implementations, I can see that both outlets leading int

Re: [akka-user] akka stream design for processing CPU+RAM intensive operations

On Tuesday, September 19, 2017 at 9:53:36 PM UTC+2, Patrik Nordwall wrote: > > You can try and compare Balance, Partition and PartitionHub. > Is the fundamental difference between GroupBy and Partition/PartitionHub the fact that the latter gives you more fine-grain control over the internal func

Re: [akka-user] akka stream design for processing CPU+RAM intensive operations

You can try and compare Balance, Partition and PartitionHub. /Patrik > On Sep 19, 2017, at 00:16, Jakub Liska wrote: > > Hey, > > having an operation that heavily utilizes CPU and RAM, nothing else (no IO), > but it is a main bottleneck, then it never pays off using `stream.mapAsync` > for it

[akka-user] PersistentFSM and event tags

Is there a way to add tags (i.e. *akka.persistence.journal.Tagged*) to domain events and *StateChangeEvent* in a *PersistentFSM* actor? I haven't been able to find anything in the documentation, so I've implemented that using an *EventAdapter*, but the solution I've found is rather complex. I w

[akka-user] Re: Source per Partition

My preliminary testing suggests that the flatMapMerge version will *not* work if the breadth value is less than maxPartitions. I don't understand why all partition sources wouldn't continue to emit and be merged. On Mon, Sep 11, 2017 at 4:27 PM, Richard Rodseth wrote: > The first two code sample

[akka-user] Akka Cluster Communication Between Two Systems

can we do cluster communication between two systems. i am trying to do but don't know how to communicate can you please help me with that i know little bit of clusterclient concept , since i am a java developer i want this in java as i don't know scala. Thanks & Regards , V . Sai Kiran Sarma

Re: [akka-user] akka.typed, is it possible a message is lost when it is send just after the creation of an actor?

I did create the following test but it passes. So far I am not sure if it is an akka bug or something else. import akka.typed.{ ActorRef, ActorSystem, SupervisorStrategy } import akka.typed.scaladsl.Actor import org.scalatest.FunSuite import org.scalatest.Matchers._ import akka.typed.scaladsl.A

Re: [akka-user] Can I create a persistent actor with timers?

Hi David, We would have to add AbstractPersistentActorWithTimers. I have created issue https://github.com/akka/akka/issues/23652 and will add it right away, since it's just a small thing. /Patrik On Sun, Sep 17, 2017 at 3:50 PM, David Pinn wrote: > I'm working with actors in Java, and I've cre