[akka-user] Reactive Kafka and Confluent

The Confluent add ons like Schema Registry are open source and the client library and Kafka itself are forks of the Apache versions. reactive-kafka seems to be "reactive Kafka for Apache Kafka". I'm wondering if folks are using it in conjunction with the Confluent offerings. -- >>

Re: [akka-user] CoordinatedShutdown

Thanks. I think I was missing my println output because I launched and stopped in Eclipse. Cntrl-C from the terminal worked fine. On Wed, May 10, 2017 at 10:23 PM, Patrik Nordwall wrote: > You can call run from anywhere, e.g. instead of calling system.terminate() >

[akka-user] Re: streams: unroll -> sequence for flow -> reroll -- howto?

Thanks for the follow up -- the idea you posted is related, but not quite it. I wrote a self-contained working example below. What I do in this example is manually materialize a graph, and wrap it as a future, making it usable by mapAsync. *Ideal: to define an entire graph such that the

Re: [akka-user] Use case for a customized dispatcher

Understood, thank you. -- >> 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

Re: [akka-user] Use case for a customized dispatcher

You likely don't need to, ever. In fact, we won't be supporting writing your own in Akka Typed. -- Konrad `ktoso` Malawski Akka @ Lightbend On 11 May 2017 at 18:20:06, Dai Yinhua (yhdai.2...@gmail.com) wrote: I don't know, I'm reading through Akka

Re: [akka-user] Use case for a customized dispatcher

I don't know, I'm reading through Akka document, so just wondering why Akka provides customized dispatcher and in what case should write customized dispatchers. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] Use case for a customized dispatcher

Hi there, I don't think you need to write a custom dispatcher - do you have evidence that you need to implement your own? -- Konrad `ktoso` Malawski Akka @ Lightbend On 11 May 2017 at 18:00:14, Dai Yinhua (yhdai.2...@gmail.com) wrote: Hi Akka team, In

[akka-user] Use case for a customized dispatcher

Hi Akka team, In http://doc.akka.io/docs/akka/current/java/dispatchers.html, it said The default dispatcher gives excellent performance in most cases I just want to know in what case the default dispatcher is not performing good, and when we write customized dispatcher, which kind of