[akka-user][deprecated] Using mapConcat with PassThroughFlow can result to a dead lock ?

Hi, I would like to have a confirmation about the usage of PassThroughFlow . Reading the documentation, the following quotes make me think that the usage I'm doing is wrong :

Re: [akka-user] Delay a gracefully shutdown when application shutdown hook has been detected

our task to one of the phases, instead of using jvm shutdown > hook. Coordinated Shutdown will be triggered by jvm exit. > > /Patrik > tis 13 feb. 2018 kl. 12:52 skrev Kilic Ali-Firat <kilic.a...@gmail.com > >: > >> Hi, >> >> I'm working on a part of my

[akka-user] Delay a gracefully shutdown when application shutdown hook has been detected

Hi, I'm working on a part of my Akka application which must gracefully shutdown when a shutdown hook has been detected. The use case of my question is in case of deployment while the application is making some tasks. In this specific case, we do want to delay the deployment until my actors

[akka-user] Re: AKKA - JAVA

Hi, You can find many examples in java reading following page : https://developer.lightbend.com/guides/ Le mardi 13 février 2018 11:09:36 UTC+1, S SATHISH BABU a écrit : > > Hello, I am new to Akka. I want to learn to develop Distributed programs. > I searched for tutorials but couldn't find

Re: [akka-user] Message processed by Actors

Hi, I will make some tests with Stash trait, it can be a good solution in my use case. Thanking for sharing your idea :) Le lundi 12 février 2018 19:13:53 UTC+1, Justin du coeur a écrit : > > On Mon, Feb 12, 2018 at 11:26 AM, Kilic Ali-Firat <kilic.a...@gmail.com > > wrot

Re: [akka-user] Slow reactive-kafka consumer when running multiple streams

Hi, I did a lot of tried and in my case, the bottleneckness was the akka-streams-kafka version. It was not aligned to my kafka server version. You have a look also to field "receive.buffer.bytes" parameter, make some tests with differents values. You also can have a look to your CPUs

[akka-user] Message processed by Actors

Hi Akka team, I have a question about messages processing by an Actor. In the context of my Akka application, I defined an Actor with a similar behavior : case class Worker() extends Actor { trait Message case class M1(x : Int) extends Message case class M2(x : Int) extends Message

Re: [akka-user] Akka Cluster Http Management Setup

t you > bound it to, see docs: > > https://developer.lightbend.com/docs/akka-management/current/akka-management.html#basic-usage > > (see port docs below) > > -- > Cheers, > Konrad 'ktoso <http://kto.so>' Malawski > Akka <http://akka.io/> @ Lightbend <h

[akka-user] Akka Cluster Http Management Setup

Hi guys, I'm started to play with Akka Cluster HTTP management. I have a project of an Akka Cluster in which I added dependencies (latest) to have informations about my cluster members. I have two seed nodes : one starting on port 2551 and other one 2552. The seed nodes are joining the

Re: [akka-user] BackOff supervisor with reactive-kafka

Ok fouded in last version 2.5.7 Le jeudi 7 décembre 2017 10:52:02 UTC+1, Kilic Ali-Firat a écrit : > > Patrick, > > I'm using akka-streams 2.4.17 and it seems that RestartSource is not > included in package akka.streams.scaladsl ? > > Am I wrong ? > > Le mardi 5 d

Re: [akka-user] BackOff supervisor with reactive-kafka

Patrick, I'm using akka-streams 2.4.17 and it seems that RestartSource is not included in package akka.streams.scaladsl ? Am I wrong ? Le mardi 5 décembre 2017 15:21:08 UTC+1, Kilic Ali-Firat a écrit : > > Hey Patrick, > > I will give a try to the Streams restart stage, in

Re: [akka-user] BackOff supervisor with reactive-kafka

to use that, and I > think that was discussed in some ticket. > > On Tue, Dec 5, 2017 at 2:45 PM, Kilic Ali-Firat <kilic.a...@gmail.com > > wrote: > >> Hi Akka, >> >> Something is unclear for me in code founded in reactive-kafka >> documentation. Below we

[akka-user] BackOff supervisor with reactive-kafka

Hi Akka, Something is unclear for me in code founded in reactive-kafka documentation. Below we are creating the supervisor using BackOff.onStop function. We are using the child props but we didn't create an actor using props. Do we need to create StreamWrapperActor with system.actorOf or the

[akka-user] Reactive-Kafka - Restart consumer stream

Hi, I'm using reactive-kafka (0.12) to consume in batch style kafka topics. Now I'm searching a way to restart the stream in case of any error. Reading the doc, recoverWithRetries is what I need but I have the following error at compile time : [error] found :

[akka-user] Alpakka MQTT - Benchmarks

Hi Akka Team, Do you have any benchmarks result to share on mqtt connector ? Because I'm facing a problem during a load tests. My current mqtt setup is a cluster of 3 nodes, I created a stream reading data coming from each mqtt node using an automatic load dispatcher provided by EMQ (Erlang

Re: [akka-user] Tunning default dispatcher seems to have no effect

). As you can see on the pictures, I have some hot periods in which actors make some stuff and during these period, I has no blocking call so it is a normal behaviour ? Le jeudi 28 septembre 2017 12:40:54 UTC+2, Kilic Ali-Firat a écrit : > > Hi, > > I will run the code in local and

Re: [akka-user] Tunning default dispatcher seems to have no effect

.g. use `jstack` on > the command line to gather some), that should give you a clue what's going > on. In the picture you sent in your first email there were actually only 8 > regular pool threads. Are there times where more is going on? > > Johannes > > On Thursday, September 28, 2017 a

[akka-user] Re: akka cluster client

Hi, Did you read that the following post : http://developer.lightbend.com/guides/akka-sample-cluster-scala/ ? Le jeudi 28 septembre 2017 11:20:22 UTC+2, Kiran Sarma a écrit : > > I am doing akka cluster client program to send messages to another cluster > but i can't find any relevant code as

Re: [akka-user] Tunning default dispatcher seems to have no effect

tc. > > — > Konrad `kto.so` Malawski > Akka <http://akka.io> @ Lightbend <http://lightbend.com> > > On 28 September 2017 at 17:35:19, Kilic Ali-Firat (kilic.a...@gmail.com > ) wrote: > > Scala version : 2.11.7 > Akka version : 2.4.17 > > - &g

[akka-user] Tunning default dispatcher seems to have no effect

Scala version : 2.11.7 Akka version : 2.4.17 - Hi Akka Team, I'm writing an Akka application using Akka Cluster, Akka Actors and Akka Stream. I have a cluster of 3 nodes : 2 workers and 1 node consuming data from a source. I want three configs files : application.conf, node.worker.conf

[akka-user] Recommand JAVA OPTS for Akka application

Hi Akka Team, I have an Akka app using Akka Streams, Akka Cluster and Akka Actors. I cannot found in the documentation some recommandations on the JAVA OPTS to set. Do you have any advices on which java opts (other than -DXms and -DXmm) to set or not ? Thanking your in advance, Alifirat

[akka-user] Re: Actor Creation runtime

Are you searching something like ? case class ActorsFactory extends Actor { case object V1 case object V2 def receive = { case V1 => context.actorOf(...) case V2 => context.actor(..) } } Le mardi 27 juin 2017 07:36:58 UTC+2, sharanya a écrit : > > Hi > > I wanted to

[akka-user] Re: Question about Reactive Kafka performances

Alex, You're right about the parameter *receive.buffer.bytes*. When using his default value, my consumer throughput is about 3 000 msg / sec when my producer send about 5000 msg / sec. When I setting the receive.buffer.bytes to a higher value, I have the same throughput than the producer.

[akka-user] Re: Question about Reactive Kafka performances

fixed it ! Le dimanche 25 juin 2017 20:50:06 UTC+2, Kilic Ali-Firat a écrit : > > I tried to add this bound on the fetch bytes but I didn't work too. > > I'm using java 1.8.0_121 and I tested something else : I'm listening a > topic in which no data has been send and I get

[akka-user] Re: Question about Reactive Kafka performances

I tried to add this bound on the fetch bytes but I didn't work too. I'm using java 1.8.0_121 and I tested something else : I'm listening a topic in which no data has been send and I get the same error ! I also tried with my old consumer in scala 2.11.7 and I have the same error. Le

[akka-user] Re: Question about Reactive Kafka performances

buffer memory [error] at java.nio.Bits.reserveMemory(Bits.java:693) [error] at java.nio.DirectByteBuffer.(DirectByteBuffer.java:123) [error] at java.nio.ByteBuffer.allocateDirect(ByteBuffer.java:311) [error] at sun.nio.ch.Util.getTemporaryDirectBuffer(Util.java:241) [error] at sun.nio.ch.IOUtil.read(I

Re: [akka-user] Question about Reactive Kafka performances

, Kilic Ali-Firat a écrit : > > Pretty weird, I have the same build.sbt than you : > > scalaVersion := "2.11.7" > > > val kafkaV = "0.10.0.1" > val reactiveKafkaV = "0.13" > > > libraryDependencies ++= Seq( > "org.apache.kafka"

Re: [akka-user] Question about Reactive Kafka performances

ed to map 139460608 bytes for committing reserved memory. # An error report file with more information is saved as: # /home/admin/reactive-hosted-kafka-benchmark/hs_err_pid1000.log Did you meet the same issue than me ? Le vendredi 23 juin 2017 23:38:17 UTC+2, Kilic Ali-Firat a écrit : >

Re: [akka-user] Question about Reactive Kafka performances

Thank you Alex, I will give a try :) Le vendredi 23 juin 2017 23:30:54 UTC+2, Kilic Ali-Firat a écrit : > > Did you do something like this ? > > libraryDependencies ++= Seq( > "com.typesafe.akka" %% "akka-stream-kafka" % "0.16" > ) > > de

Re: [akka-user] Question about Reactive Kafka performances

lients should not be enough to get the same speedup .. Le vendredi 23 juin 2017 23:27:43 UTC+2, Alex Cozzi a écrit : > > yes, in our dependencies we do not only include reactive kafka, but also > explicitly the dependencies on kafka libs so that we can force 0.10.0.1. > > > On

Re: [akka-user] Question about Reactive Kafka performances

g in compatibility mode). > > On Friday, June 23, 2017 at 10:10:20 AM UTC-7, Kilic Ali-Firat wrote: >> >> *kafka broker is kafka_2.11-0.10.0.0 > > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>

Re: [akka-user] Question about Reactive Kafka performances

*kafka broker is kafka_2.11-0.10.0.0 -- >> 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

Re: [akka-user] Question about Reactive Kafka performances

with (or closed) to the kafka broker version. Le vendredi 23 juin 2017 15:43:18 UTC+2, Kilic Ali-Firat a écrit : > > Hi Patrick, > > Running in a local kafka, I can have the same throughput than the kafka > producer. > > But running in a hosted kafka, I cannot get the same throug

Re: [akka-user] Question about Reactive Kafka performances

connection to Kafka (the hosted one). Le vendredi 23 juin 2017 12:13:45 UTC+2, Kilic Ali-Firat a écrit : > > Hi Patrick, > > I attached a tarball with only the reactive kafka lib and a Main class > with how I'm using the reactive API. > > There is a README explaining how to rep

Re: [akka-user] Question about Reactive Kafka performances

vendredi 23 juin 2017 10:51:09 UTC+2, Patrik Nordwall a écrit : > > I'd recommend that you create a minimized example without addition > external dependencies. Then I or someone can run it and perhaps see what is > the culprit. > > /Patrik > fre 23 juni 2017 kl. 00:15

Re: [akka-user] Question about Reactive Kafka performances

Like you said, 2000 msg / sec is really relly slow. The reactive Kafka consumer should consume at the same speed than the producer. Reading the benchmark examples in GitHub plus the benchmarks result in your link didn't help me to catch what I am doigt wrong. I respect the way to use the

[akka-user] Akka cluster and ReactiveMongo issue

Hi Akka team, I have a Akka application with a cluster of 3 three nodes. My app uses two external libs using in internal Akka : RedisScala and ReactiveMongo. In one node, I'm using only Redis Scala and in the other nodes, I'm using Redis Scala and Reactive Mongo. My current problem is

[akka-user] Re: Akka Cluster - Node not joining the Cluster

of-your-seed must be the IP of the first node you started. > > On Friday, May 5, 2017 at 3:35:39 PM UTC+2, Kilic Ali-Firat wrote: >> >> Hi Akka Team, >> >> To prepare a deployment using docker, I try to start in my laptop a >> cluster with 3 nodes : 2 nodes wor

[akka-user] Akka Cluster - Node not joining the Cluster

Hi Akka Team, To prepare a deployment using docker, I try to start in my laptop a cluster with 3 nodes : 2 nodes workers (seed-nodes) and 1 node as cluster client. When I start the first seed node and then second one, this last is not joining the cluster as expected. I follow the instructions

[akka-user] Multi Nodes Spec - Message send more than once

Hi Akka Team, It's again me about the multi-nodes test that I'm doing to validate my cluster. I solve my issues about Master-Worker communication but I have a really weird behavior in my test. The below piece of code seems to be execute 3 three times : awaitAssert { /**

[akka-user] Re: Cluster Group Router - Routees cannot receive messages

I solved my issue with changing the roles names ! Le jeudi 30 mars 2017 18:01:51 UTC+2, Kilic Ali-Firat a écrit : > > Hi Akka Team, > > Using the akka cluster samples, I defined a cluster router (group) and I > want to validate my cluster using unit test. > > The probl

[akka-user] Cluster Group Router - Routees cannot receive messages

Hi Akka Team, Using the akka cluster samples, I defined a cluster router (group) and I want to validate my cluster using unit test. The problem is that the master receive the job (an Akka message) to execute and when I send the job to the workers, it forwards to the dead lettters :

Re: [akka-user] [Akka Actors] - Akka Cluster newbie and advices

> > If you need something even more dynamic you can use Distributed PubSub as > a router. > > Regards, > Patrik > fre 10 mars 2017 kl. 23:33 skrev Kilic Ali-Firat <kilic.a...@gmail.com > >: > >> Hi Akka hackers, >> >> I wrote a first version of

[akka-user] [Akka Actors] - Akka Cluster newbie and advices

Hi Akka hackers, I wrote a first version of a application using Akka Actors with only Actors fetching data from Kafka. This version works well and now I preparing a new version using Akka Cluster to scale it. In my application scope, process means : 1. Read data from kafka 2.

[akka-user] Akka cluster - reactivemongo.api.MongoConnection not serializable

Hi, In a context of akka cluster with several nodes, I got the below exception : [info] akka.remote.MessageSerializer$SerializationException: Failed to serialize remote message [class akka.remote.DaemonMsgCreate] using serializer [class akka.remote.serialization.DaemonMsgCreateSerializer].

[akka-user] Re: Define a SupervisorStrategyConfigurator

asses folder to make sure. > > cheers, > Rafał > > W dniu wtorek, 17 stycznia 2017 16:35:07 UTC+1 użytkownik Kilic Ali-Firat > napisał: >> >> Hi guys, >> >> After reading more the documentation about the fault tolerance in Akka, >> I'm trying to a define a

[akka-user] Define a SupervisorStrategyConfigurator

Hi guys, After reading more the documentation about the fault tolerance in Akka, I'm trying to a define a new guardian supervisor strategy like below : package foo import akka.actor.{OneForOneStrategy, SupervisorStrategy, SupervisorStrategyConfigurator} import

Re: [akka-user] Misunderstand about Resume strategy

t. Also, because I'm in a test environment, do I need to do something special when create a child of actor system ? Le jeudi 12 janvier 2017 14:41:11 UTC+1, Konrad Malawski a écrit : > > > On Thu, Jan 12, 2017 at 2:31 PM, Kilic Ali-Firat <kilic.a...@gmail.com &

Re: [akka-user] Re: Akka application.conf does not override values in reference.conf

; should just pass the `config` to the system, not the `akkaConfig`. > > Regards, > > Roland > > 15 dec. 2016 kl. 10:02 skrev Kilic Ali-Firat <kilic.a...@gmail.com > >: > > And I forgot to mention that : I also tried to have one application.conf > file with the a

[akka-user] Re: Akka application.conf does not override values in reference.conf

And I forgot to mention that : I also tried to have one application.conf file with the akka config but it's not working too .. Le jeudi 15 décembre 2016 09:53:55 UTC+1, Kilic Ali-Firat a écrit : > > Hi Akka Team, > > I wrote an Akka application using actors and now, I want to ma

[akka-user] Akka application.conf does not override values in reference.conf

Hi Akka Team, I wrote an Akka application using actors and now, I want to make some load tests and plays with the akka configurations. It's a sbt project with the following structure : . ├── main │ ├── resources │ │ ├── akka.conf │ │ ├── application.conf │ │ └── log4j.properties

[akka-user] Re: Hashing Router vs Actor System with childs

f that does everything you need: > http://doc.akka.io/docs/akka/2.4.14/java/cluster-sharding.html > > HTH, > > Guido. > > On Sunday, December 4, 2016 at 9:10:32 AM UTC, Kilic Ali-Firat wrote: >> >> Hi, >> >> The purpose to have pool is to have a cluster o

[akka-user] Hashing Router vs Actor System with childs

Hi everyone, I would like to have some advices from the akka experts. These month, I working on a use case in which I fetched data from Kafka. I have a set of devices (which will grown in time) pushing their data to Kafka and I need to fetch them. I know that there is a library