Re: [akka-user] [akka-streams] Resource pool for use within a flow

You could probably do something like that, but there is nothing that does it out of the box. It would not really need to be blocking either, it could be modeled as a Source that only emits resource instance handles when they are available. The problem then becomes to signal being done with a resou

Re: [akka-user] Akka HTTP bind exception on Windows

Hi Michael, No, Akka HTTP uses Akka's own TCP stack, we don't use Netty there. I guess we should just fix this in the next release. -Endre On Fri, Apr 8, 2016 at 8:47 AM, Michi wrote: > Hi, > > is Akka HTTP still using Netty? To solve the problem I built a small HTTP > server using Netty that

Re: [akka-user] Akka HTTP bind exception on Windows

And to clarify, by "we", anyone reading this or the Issue is eligible for fixing it :) On Fri, Apr 8, 2016 at 10:11 AM, Endre Varga wrote: > Hi Michael, > > No, Akka HTTP uses Akka's own TCP stack, we don't use Netty there. I guess > we should just fix this in the next release. > > -Endre > > On

Re: [akka-user] Akka HTTP bind exception on Windows

But first, please file a ticket! On Fri, Apr 8, 2016 at 11:24 AM, Viktor Klang wrote: > And to clarify, by "we", anyone reading this or the Issue is eligible for > fixing it :) > > On Fri, Apr 8, 2016 at 10:11 AM, Endre Varga > wrote: > >> Hi Michael, >> >> No, Akka HTTP uses Akka's own TCP sta

Re: [akka-user] Akka HTTP bind exception on Windows

And if you want to do the PR first, then I'll open the ticket for you :) On Fri, Apr 8, 2016 at 11:58 AM, Endre Varga wrote: > But first, please file a ticket! > > On Fri, Apr 8, 2016 at 11:24 AM, Viktor Klang > wrote: > >> And to clarify, by "we", anyone reading this or the Issue is eligible f

[akka-user] Best practice for consuming a Http response entity's data stream

If I want to consume a Http service and then do something with the response body, there are a couple of ways to go about doing that. The two ones that I am trying to decide between are: val f:Future[ByteString] = Source.single(req). via(outgoingConn). flatMapConcat(

Re: [akka-user] Best practice for consuming a Http response entity's data stream

On Fri, Apr 8, 2016 at 1:06 PM, Chris Baxter wrote: > If I want to consume a Http service and then do something with the > response body, there are a couple of ways to go about doing that. The two > ones that I am trying to decide between are: > > val f:Future[ByteString] = > > Source.

[akka-user] ANNOUNCE: Released akka-stream-kafka 0.11-M1

Are there plans WRT akka persistence on kafka? -- >> 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 receive

Re: [akka-user] ANNOUNCE: Released akka-stream-kafka 0.11-M1

There is https://github.com/krasserm/akka-persistence-kafka as a community maintained project. /Patrik On Fri, Apr 8, 2016 at 2:32 PM, David Pennell wrote: > Are there plans WRT akka persistence on kafka? > > -- > >> Read the docs: http://akka.io/docs/ > >> Check the FA

Re: [akka-user] Best practice for consuming a Http response entity's data stream

Thanks for responding Viktor. 1) I see the flaw in this design (flatMapConcat) now. If the response is chunked you only read the first chunk 2) I want to be able to parse the body as json and have the final result of the flow be a Future for some object that I have mapped the response json to.

Re: [akka-user] Best practice for consuming a Http response entity's data stream

None of the out of the box Unmarshallers for json (like SprayJsonSupport) support parsing in a lazy and streaming way. I did find this repo which looks promising: https://github.com/knutwalker/akka-stream-json Is this the best kind of approach? It's certainly nice in that you don't have to r

Re: [akka-user] Why should nodes usually not include themselves in seed node list?

It's only the first node in the seed nodes list that is special. It's only that one that will join itself to bootstrap the cluster, after it has tried joining the other nodes. Sorting is fine. For the AWS part you might get something from this blog post: http://chrisloy.net/2014/05/11/akka-cluste

Re: [akka-user] Stream Testkit expectNextType ?

Hi Derek, Sounds like a great addition. Will you take a stab at it? /Patrik On Thu, Apr 7, 2016 at 9:59 PM, Derek Wyatt wrote: > Hi guys, > > I've been writing some tests for my stream code and have run up against a > situation where I would like to have expectNextType. I've implemented > this

Re: [akka-user] Akka persistence - errors on the read side

On Thu, Apr 7, 2016 at 5:17 PM, Richard Rodseth wrote: > Also, seeing the work in reactive-kafka to allow the following, I wonder > if this is making you rethink akka-persistence-query APIs > Why? What is wrong? Persistence query api also has an offset parameter that can be used as the starting

[akka-user] In Akka how does cassandra react when it is full and cannot persist more messages

In Akka we are using cassandra to persist data. Does Akka automatically cleanup cassandra based on timestamp of messages or do we need to manually (in code) do it? If so any pointers would be helpful. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>>

Re: [akka-user] Akka Streams Remote Materialization

No news. We are currently not working on it. You can keep an eye on what is done in Gearpump. http://www.gearpump.io/ http://www.marketwired.com/press-release/lightbend-announces-collaboration-bring-low-latency-high-availability-big-data-2099511.htm On Wed, Apr 6, 2016 at 11:14 PM, César Aguiler

Re: [akka-user] Dstributing data in akka cluster (guidance needed)

Take a look at Akka Distributed Data and perhaps you can add the durability as a separate concern. /Patrik On Tue, Apr 5, 2016 at 10:37 PM, Val P wrote: > HI, > > I am looking for guidance, if anyway is willing to share their expe

Re: [akka-user] Re: Akka Persistence with Cassandra

Are you using Cassandra 3.x? Read up on the compatibility aspects in the README: https://github.com/akka/akka-persistence-cassandra On Wed, Apr 6, 2016 at 5:59 AM, Madabhattula Rajesh Kumar < mrajaf...@gmail.com> wrote: > Hi, > > If I use below application.conf (default settings). > > akka { >

[akka-user] Compiler saying "NotUsed" should be "BoxedUnit"

Hi Folks, I'm trying out the tutorial on Akka Streams (Java) and the following line of code from the tutorial: final Source source = Source.from(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)); causes a compilation failure. It says that "NotUsed" should be a BoxedUnit. Not really a big prob

Re: [akka-user] Akka persistence - errors on the read side

Sorry, I'm probably confused. I don't think I've seen a full example of an Akka Persistence projection, including error handling and saving offsets persistently. So the infinite stream API seems to be of dubious value unless you don't care about resilience: val willNotCompleteTheStreamTagged: Sour

Re: [akka-user] Compiler saying "NotUsed" should be "BoxedUnit"

Don't mix these versions. Akka streams is part of Akka since 2.4.2, among others also for exactly this reason. Please use Akka streams 2.4.2 with akka 2.4.2. Same with 2.4.3, etc. They move together now. Happy talking! On Apr 8, 2016 18:43, "James P" wrote: > Hi Folks, > > I'm trying out the tu

Re: [akka-user] Compiler saying "NotUsed" should be "BoxedUnit"

Thanks Konrad! I initially did not see the "akka-streams" on maven, I was using "akka-streams-experimental". Everything is working fine now after importing akka-streams 2.4.3. By the way, Akka streams is amazing! Makes a lot of things that I need to do much much simpler :) Have a great weeke