Re: [akka-user] Re: Akka Streams: Best business case to implement

If you’re looking for companies / descriptions of projects who used Akka or any of those other technologies and how it worked out for them then perhaps you’ll enjoy the collection of customer whitepapers collected on https://www.lightbend.com/learn These are written by Lightbend customers, and are

Re: [akka-user] A custom loop in a BidiGraph

No, that would break semantics upon which all of the guarantees Akka Streams (and Reactive Streams) provide. Basically if you can not push, you need to keep the element somewhere, and await being pulled from that side again. On June 14, 2017 at 9:51:03 AM, Hussachai Puripunpinyo (hussac...@gmail.

Re: [akka-user] Send null message to cluster receptionist

Why are you sending null messages? That’s illegal - end of topic on that point. Regarding the other one - no idea without you providing more details what your system actually is. — Konrad On June 16, 2017 at 11:47:00 PM, prateek singhal (prateek.itm...@gmail.com) wrote: Hi, I am getting follow

Re: [akka-user] Strange java.lang.VerifyError with ActorSystem initialization

It’s rather unlikely that Akka itself is at fault here. You could try using the latest version of the lib etc, however I don’t think that’s it… Do other java apps work in your env (are you sure it’s not weird / broken)? On June 19, 2017 at 10:36:34 PM, Matlik (james.mat...@gmail.com) wrote: I'm

Re: [akka-user] Strange java.lang.VerifyError with ActorSystem initialization

These crazy things are best debugged locally to be honest. Try cleaning your ivy caches, maybe the jar file got corrupted somehow etc? On June 20, 2017 at 2:28:26 PM, Matlik (james.mat...@gmail.com) wrote: I find it strange that it would be Akka, but this does appear to only impact the Akka/Scal

Re: [akka-user] Dependency injection in Akka Http

Hi there Amer, DI is one thing, but “DI frameworks” is quite another. I for one am not a big fan of frameworks taking much control over this, however any tool/framework you want to use will “just work”, it’s just creating objects after all - Akka is very simple in that sense, no magical registries

Re: [akka-user] akka-streams: what causes the downstream to be "cancelled"/onDownstreamFinish called?

Could you share the full snippet? The code as pasted above would not cancel (downstream cancels, but a Sink.ignore never would cancel). Are you sure you’re not terminating the app or something else that would cause the stream to stop? — Konrad On June 27, 2017 at 3:23:04 AM, Josh F (jof...@gmail.

Re: [akka-user] Max number of cluster nodes

We’re currently preparing for such large-scale scalability test on the new remoting. How many nodes are you expecting more or less from memory per user estimates etc? — Konrad On 30 June 2017 at 02:43:43, Eduardo Fernandes (edu...@gmail.com) wrote: Hi all. I'm starting a new project and I'm wo

Re: [akka-user] Max number of cluster nodes

Are those in different data centers or one? We’re also working on multi-dc features, which limit the chatty-ness between datacenters, allowing for even greater scalability. The interesting question to ask if they are indeed one logical unit and clustering them all indeed is the thing to do or not.

Re: [akka-user] How to download and install newest Akka

Akka is just a Scala/Java library, you’d use it like any other Scla/Java library. So you could add it as dependency in your maven file, or first learn how to use sbt: http://www.scala-sbt.org/ and to the same there. Akka dependencies are listed on http://akka.io/docs/ Happy hakking — Konrad On

Re: [akka-user] Re: Akka http -ERROR :Substream Source cannot be materialized more than once If Payload size increased

I’d recommend using the search function on the docs: http://doc.akka.io/docs/akka-http/current/scala/http/routing-dsl/directives/basic-directives/extractStrictEntity.html#extractstrictentity The search function on the left would get you to this directive as well as the toStrict method. Also read t

[akka-user] Re: Akka Typed and MDC

Akka Typed is still not quite "done" so missing or undecided upon APIs may still be here and there. That's one of them, so I opened a ticket to discuss and decide what to do about it in Typed. https://github.com/akka/akka/issues/23326 Having that said, you can always just directly use the loggi

[akka-user] Re: Akka Typed and MDC

Once I wrote the response I though that for using the library directly you'll also want to know about the possibility to implement: /** * Extension point for implementing custom behaviors in addition to the existing * set of behaviors available through the DSLs in [[akka.typed.scaladsl.Actor]]

Re: [akka-user] Re: Akka Typed and MDC

The "power mode” ;-) On 11 July 2017 at 00:02:12, Justin du coeur (jduco...@gmail.com) wrote: Oh, sweet -- ExtensibleBehavior looks enormously useful... On Mon, Jul 10, 2017 at 9:29 AM, Konrad 'ktoso' Malawski wrote: > Once I wrote the response I though that for using th

Re: [akka-user] Re: withSupervisionStrategy passed a japi Function but compiler complains that its expecting a scala Function1

...@lightbend.com) wrote: Well that's exactly the thing we fixed. As you've found in the docs. We'll release a stable this week, please upgrade then. -- Konrad `ktoso` Malawski Akka <http://akka.io> @ Lightbend <http://lightbend.com> On 26 October 2016 at 13:29:52, murtu

Re: [akka-user] Re: Akka Camel and Akka Streams

And it is listed under Alpakka projects too :-) http://developer.lightbend.com/docs/alpakka/current/external-connectors.html#camel — Konrad On 12 July 2017 at 15:06:01, 'Martin Krasser' via Akka User List ( akka-user@googlegroups.com) wrote: Hi Andreas, the replacement for akka-camel is the S

Re: [akka-user] Akka Streams - UDP messages

Hi there, you do realize that UDP, the protocol itself, does not guarantee delivery of anything? It absolutely may and will in practice drop packets - it is designed to do exactly that. Start reading about UDP here https://en.wikipedia.org/wiki/User_Datagram_Protocol and take it from there to netw

Re: [akka-user] Use of high performance bounded mail box.

The current default, more than anything, is bound to be the default since it was the default since the inception of Akka and going for a bounded one by default now could make some users unhappy. Having that said, we're actively looking forward to pick a bounded impl for Akka Typed. Then people com

Re: [akka-user] Akka Typed API discussion

Hi Bryan, The forum differs a bit depending on what you want to chat about. Do you have a few issues to talk about and they’re specific enough (and potentially could have an actionable outcome I’d assume/hope)? Then http://github.com/akka/akka would be the best, one ticket per specific issue, not

Re: [akka-user] Akka-Typed MutableBehavior: return type of onMessage

Exactly the same. Becoming an different behavior. On July 19, 2017 at 0:16:18, Mushtaq Ahmed (mushta...@gmail.com) wrote: > Actor.immutable returning Behaviour[T] makes sense as it uses recursion to > return updated state or Actor.stopped etc. > > But in MutableBehavior, I end up using this patte

Re: [akka-user] [ANNOUNCE] ChanaMQ - an Akka based AMQP messaging broker

Dispatchers are documented http://doc.akka.io/docs/akka/current/scala/dispatchers.html ForkJoinPool based. Stages get fused so it’s a bit more tricky than that. — Konrad `kto.so` Malawski Akka @ Lightbend On 28 July 2017 at 05:49:20, Caoyuan (dcaoy...@gmai

Re: [akka-user] Persistence Query and Sharding

*Eventually* all events with the given tag. Note also that that stream is infinite, unlike the “currentEventsByTag” which is finite and whatever was currently visible by that tag when it was reading. — Konrad `kto.so` Malawski Akka @ Lightbend On 1 August 2

Re: [akka-user] Consuming akka-streams service via Javascript

Hi there, In general “streaming consumption" of such API can be simplified to “start working with the data before the entire transfer completes. Since it’s JSON you likely want to parse it somewhat, or select specific elements etc. AFAICS http://oboejs.com/examples is one of the streaming parsers

Re: [akka-user] Persistence Query and Sharding

Cool! Are we talking in the order of seconds here? Is it dependent on polling with an adjustable interval? There’s different modes: https://github.com/akka/akka-persistence-cassandra/blob/v0.54/core/src/main/resources/reference.conf#L244 How does the offset parameter work with eventsByTag? The e

Re: [akka-user] akka-1.3.1.xsd schema location

Hi there, you could get them from here: https://github.com/akka/akka.github.com/tree/968159d916d9a54c5d247c5b228398e1e0d43d68 (old version of what was the website, and had all these files). — Konrad `kto.so` Malawski Akka @ Lightbend On 1 August 2017 at 17

Re: [akka-user] Consuming akka-streams service via Javascript

Yes, since we translate reactive streams back-pressure onto TCP flow control which has tot be handled (and is handled) by anything that speaks TCP, which includes any HTTP call. — Konrad `kto.so` Malawski Akka @ Lightbend On 2 August 2017 at 02:35:35, B Wil

Re: [akka-user] Flow.fromSinkAndSource and backpressure

Hi Jeff, Alexey, that’s not correct, back-pressure works there - because it has to: it is enforced by the reactive-streams protocol that we follow by heart in Akka streams. Yes, back-pressure works, the one sentence explanation would be: “independently on each side of the newly constructed flow”.

Re: [akka-user] Flow.fromSinkAndSource and backpressure

Good point, I missed that word in the question - thanks and sorry about that :) A full clarification was still useful I hope though, cheers! — Konrad `kto.so` Malawski Akka @ Lightbend On 2 August 2017 at 15:45:51, Alexey Shuksto (seig...@gmail.com) wrote:

Re: [akka-user] Akka and Mesos: Will it blend?

This is great, thanks for the initiative :-) We’ll review shortly! — Konrad `kto.so` Malawski Akka @ Lightbend On 4 August 2017 at 22:27:50, Dragos Dascalita Haut (ddrag...@gmail.com) wrote: FWIW, I'm reviving this thread to share that I've opened a PR wit

Re: [akka-user] [Akka-typed] Mutable Behavior testing with EffectfulActorContext

Hi there, this was fixed https://github.com/akka/akka/pull/23361 and will be released (the fix) in 2.5.4 shortly. Happy hakking — Konrad `kto.so` Malawski Akka @ Lightbend On 6 August 2017 at 23:52:11, Nishant Vishwakarma (nishant...@gmail.com) wrote: *Ef

Re: [akka-user] Performance of Akka-Http 2.5.4

When wanting to discuss any benchmarks, please share actual code as otherwise it's impossible to comment on what you're actually benchmarking. Same goes for benchmark setup, you did not explain how the benchmark was run and what network it was on etc. We have continuously confirmed same performanc

Re: [akka-user] Akka cluster on Hadoop YARN

There has not been much interest in that from what I can cell. Rather people are using k8s, marathon/mesos etc to run Akka applications nowadays. — Konrad `kto.so` Malawski Akka @ Lightbend On 15 August 2017 at 12:03:14, Juan Rodríguez Hortalá ( juan.rodrig

Re: [akka-user] [Akka HTTP] Respond with a partially streamed JSON object

Nested streaming is somewhat tricky. You could achieve the actual streaming semantics with injecting the things around it, via something like `Source(the "header") concat streamingSource concat Source(“the ending ]]}]]}]”)` We have tools coming for streaming nested parsing, but not rendering so

Re: [akka-user] Pause an actor with a GraphStage -> how to validate if is open when what I have is a future?

Share full code please. It’s hard to guess what you’re doing from snippets. state.map( Looks unsafe. Is this a Future? You’re invoking internal state methods from outside threads which is unsafe and will not work if it is. Read about asyncCallback in GraphStage docs if that is the case. —

Re: [akka-user] Speeding up actor system boot time in testing environment

Still, why not do this in the same ActorSystem if you’re so concerned about start time. I’d also guess that that time is your actors or things starting, not just the AS, so cut down on things there. — Konrad `kto.so` Malawski Akka @ Lightbend On 28 August 2

Re: [akka-user] akka cluster + kryo

I would not encourage setting scala.Product or java.lang.Object as kryo serialized - pick specific classes (this is also for security reasons actually). Or create a marker type that you’d include in your messages that are to be serialized using kryo and use that. Sure you can use Artery if you wan

Re: [akka-user] Akka-Http - Multipart file upload - SubscriptionTimeoutException

Please ask in one spot at the same time - it’s difficult to track and match all the questions-that-already-were-answered.. Please also include code when asking such questions - I have to *guess* that you used the fileUpload directive, but that’s not the only way to handle uploads, so we’re left gu

Re: [akka-user] Require an Untyped ActorContext in testing

This is simply not implemented yet. As you’ve likely noticed with the big warning on the typed docs page – it’s in an early preview mode and not all things are implemented currently. — Konrad `kto.so` Malawski Akka @ Lightbend On 24 August 2017 at 18:39:01,

Re: [akka-user] AKKA nodes gets disconnected without code interaction on virtual machines

What are your actors doing? Are you blocking somewhere? It should “just work”. Please upgrade to an actually maintained version too please - 2.3 is very ancient, please use the current release timeline 2.5 – there should be almost no code changes you need to do btw, it’s compatible. — Konrad `kt

Re: [akka-user] Auto downing and Akka Cluster

Igor, that’s basically the thing: - “They merge” if you *don’t* DOWN, but things are stay in UNREACHABLE then, which could be fine in your use case. - If you DOWN, there’s no way back. You said you never want to talk to it again, and we’re guaranteeing that. Docs on the state transitions are here

Re: [akka-user] Auto downing and Akka Cluster

Let’s stick to Akka terminology as otherwise it gets confusing :-) Simply put: there is no re-join. You simply never DOWN, the node will “come back (from UNREACHABLE)” state, and things will just work - when using only AP features such as DData. Yeah, perhaps we could spell out that certain featu

Re: [akka-user] Problem of routing different java objects with same id to same actor

For reference - cluster sharding can also be used on just a single node (weird, but true ;-)). It handles the situation well and also creates actors for ids that don’t yet have an actor running etc. — Konrad `kto.so` Malawski Akka @ Lightbend On 30 August

Re: [akka-user] Source.fromFutureSource. Error handling and return type signature

Hi there Victor, That’s the “materialized value” type parameter: read the docs to learn more about it: - http://doc.akka.io/docs/akka/current/scala/stream/stream-flows-and-basics.html#defining-and-running-streams - http://doc.akka.io/docs/akka/current/scala/stream/stream-composition.html#materializ

Re: [akka-user] Akka Persistence and avoiding var in favor of context.become

Become “should" work AFAIR, though I’d recommend using Akka 2.5 (it’s binary compatible with 2.4, so you can just upgrade it). I could not find if we fixed anything about become in persistent Actors, there were fixes but a very long time ago in 2.3.. I would recommend avoiding become with Persiste

Re: [akka-user] akka-http WebSockets with separate Sink and Source

You seem to be logging on debug level there - are you sure your logging configuration is such that it will log/print log statements? On September 16, 2017 at 5:18:19, Jakub Janeček (janecek.ja...@gmail.com) wrote: > Hello, > > I am trying to implement a simple WebSockets server using akka-http wi

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.

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] Getting last message from Kafka

Same as in “normal” Kafka, you’d have to know the offset I guess. — Konrad `kto.so` Malawski Akka @ Lightbend On 21 September 2017 at 06:36:17, Zlatko Josic (zlatko.jo...@gmail.com) wrote: Hi, Can I get last published message on Kafka's topic using akka s

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

It all depends on exactly what operations you’re doing… Please share a minimised reproducer so we could advice. Error handling works as documented and is “forward propagated” through a stream, and operators are free to handle it in any way they want. — Konrad `kto.so` Malawski Akka

Re: [akka-user] Re: Where to download installer for latest Akka for Windows?

The dependencies are listed here: http://akka.io/docs/ Please use some form or widely accepted built tool, like sbt, gradle or maven to build akka projects. If you really insist on downloading jar files, you can do so directly via searching maven central http://search.maven.org/#search|ga|1|akka-a

Re: [akka-user] Akka Http memory leak suspect

What are you doing in the app ;-) Sounds to me like you’re starting tons of things that are never stopped. — Konrad `kto.so` Malawski Akka @ Lightbend On 25 September 2017 at 17:38:57, Bartosz Jankiewicz ( bartosz.jankiew...@gmail.com) wrote: I have been r

Re: [akka-user] Akka Http memory leak suspect

gt;> Visit this group at https://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >>> -- >> >>>>>>>>>> Read the docs: http://akka.io/docs/ >> >>>>>>>

Re: [akka-user] Akka Stream - Framing silently swallows exceptions?

On 26 September 2017 at 10:47:44, Fabio Tiriticco (fabio.eur...@gmail.com) wrote: Hi all, I noticed that the Framing flow of Akka Streams tends to stop the stream without letting the outer world know. In essence, the stream just stops and supervision is not triggered. It propagates errors through

Re: [akka-user] Stopping of PersistentActor

Don’t use PoisonPill, but your protocol level messages to signal “plz stop”, which is best practice anyway, — Konrad `kto.so` Malawski Akka @ Lightbend On 26 September 2017 at 17:25:43, Yaroslav Klymko (t3h...@gmail.com) wrote: Hi Guys, Do I understand co

Re: [akka-user] Stopping of PersistentActor

Sure Konrad, that's more like an example. The example is very specific, and not the recommended way. But even using own custom message and then calling context.stop will give similar effect. No, it’s different since it’s not an auto handled message. You can do whatever you want in response to y

Re: [akka-user] Anyone can take a look at http://doc.akka.io/ ? it is down

Thanks for reporting (and numerous others via twitter ;-)). We’re aware of the issue, and have fixed it for now. We’ll investigate some more though. The vm hosting the docs got corrupted and stopped being able to serve the docs. — Konrad `kto.so` Malawski Akka @ Lightbend

Re: [akka-user] Why does Flow.mapConcat() need an Iterable, vs. an Iterator?

Are multiple iterators ever needed to be requested from it? I'm kind of tempted to do Flow.>create().mapConcat(iter -> new Iterable() { @Override public Iterator iterator() { return iter; }}).grouped(chunkSize).map(list -> list.iterat

Re: [akka-user] Is there an Akka stream mapAsync equivalent for yielding a Source?

flatMapConcat / flatmapMerge ;-) — Konrad `kto.so` Malawski Akka @ Lightbend On 28 September 2017 at 15:28:49, Christopher Hunt (hunt...@gmail.com) wrote: Hey everyone, Given that mapAsync yields a Future, I was looking for a similar type of stage that yi

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

This is now how a fork-join pool works basically. Please read the docs about managing blocking: https://doc.akka.io/docs/akka/2.5/scala/dispatchers.html#blocking-needs-careful-management Tuning the default dispatcher like you’re attempting to here would not have a positive effect by the way. Plea

Re: [akka-user] Re: GraphStageActor and ActorGraphInterpreter

This is explained in this blog post: https://akka.io/blog/2016/07/06/threading-and-concurrency-in-akka-streams-explained and the docs: https://doc.akka.io/docs/akka/current/scala/stream/stream-parallelism.html#pipelining-and-parallelism Thanks for sharing your repo, I think it’s a bit weird to gu

Re: [akka-user] [akka-streams] Shared Materializer in akka extensions

Have users pass it in ;) — Konrad `kto.so` Malawski Akka @ Lightbend On 30 September 2017 at 10:04:48, Jeff (jknight12...@gmail.com) wrote: I am building an akka extension, but there doesn't seem to be an elegant way to pass in a shared Materializer. What

Re: [akka-user] [akka-streams] Shared Materializer in akka extensions

When they use it; def use(...)(implicit m: Materializer) — Konrad `kto.so` Malawski Akka @ Lightbend On 30 September 2017 at 11:18:16, Jeff (jknight12...@gmail.com) wrote: How, exactly. You only have access to an ExtendedActorSystem inside of createExtens

Re: [akka-user] [akka-streams] Shared Materializer in akka extensions

Again: what are you building? ;-) It’s very hard to provide answers if you don’t provide context. — Konrad `kto.so` Malawski Akka @ Lightbend On 30 September 2017 at 11:23:19, Jeff (jknight12...@gmail.com) wrote: That's what I was leaning towards as well,

Re: [akka-user] [akka-streams] Shared Materializer in akka extensions

So rather unlikely people will want access to your materialiser there. The sharing of materializer is most important for lifecycle - killing a materializer kills all streams it hosts, so in your case it’s unlikely you want to bind your streams to random other people’s streams lifecycles. I suggest

Re: [akka-user] Akka Cluster with different seed node sequence

Hi Prateek, No, this is a misunderstanding of how seed-nodes work. The first node in that list MUST be the same node if using the seed-nodes process. What you did by making each node have it’s own address as the first in their seed node list is form 3 independent clusters. This works as intended;

Re: [akka-user] Changed osgi.ee requirement in Akka 2.5.6

Hi there, Its not an intended change as far as I can see. Could you open a ticket please? ( GitHub.com/Akka/Akka ) We’ve been upgrading plugins to enable publishing with jdk9 recently so something must have happened to abt-Osgi during that On October 7, 2017 at 8:16:40, Oliver Heger (oheg...@gmai

Re: [akka-user] yourkit CPU ignore list

ForkJoin noice mostly – people sometimes panic about ForkJoinPool#scan specifically (which shows up when there’s nothing to do, so it spins looking for work). — Konrad `kto.so` Malawski Akka @ Lightbend On 10 October 2017 at 18:47:37, Sam Halliday (sam.hal

Re: [akka-user] yourkit CPU ignore list

erialize? Or does that indicate a problem with the way play is setup? On 10 October 2017 at 10:49, Konrad “ktoso” Malawski wrote: > ForkJoin noice mostly – people sometimes panic about ForkJoinPool#scan > specifically (which shows up when there’s nothing to do, so it spins looking > for wo

Re: [akka-user] Uncaught error from thread - ContentType$WithMissingCharset

The exception is pretty clear about something being wrong with dependencies: > java.lang.NoClassDefFoundError: akka/http/scaladsl/model/ContentType$WithMissingCharset How do you configure this project? What’s your dependencies / build file / build system? — Konrad `kto.so` Malawski Akka

Re: [akka-user] Uncaught error from thread - ContentType$WithMissingCharset

Actually depend on akka-http 10.0.10 and akka 2.5.6 ;-) — Konrad `kto.so` Malawski Akka @ Lightbend On 11 October 2017 at 10:15:34, bordec...@gmail.com (bordec...@gmail.com) wrote: Thanks for quick reply, Konrad. Actually, I'm using - these json parsing d

Re: [akka-user] Uncaught error from thread - ContentType$WithMissingCharset

Weird indeed; With regards to versions, please always use the latest - esp when reporting issues like this. Please try 10.0.10 and 2.5.6 as I suggested above. Can you post a reproducer (repository) where we could reproduce this? — Konrad `kto.so` Malawski Akka @ Lightbend

Re: [akka-user] [akka-http] Virtual hosts

What’s the actual use case? By itself no. — Konrad `kto.so` Malawski Akka @ Lightbend On 11 October 2017 at 14:44:59, Slowaner (turchaninov.nik...@gmail.com) wrote: Is there any feature to bind many virtual hosts at one interface with same listening IP an

Re: [akka-user] [akka-http] Virtual hosts

Simply Http().bind two times given the same routes ;) Though in reality people would hide akka-http behind ngnix or something similar and do the tls things there very often. — Konrad `kto.so` Malawski Akka @ Lightbend On 11 October 2017 at 15:10:34, Slowan

Re: [akka-user] Uncaught error from thread - ContentType$WithMissingCharset

Happy hakking, cheers :) — Konrad `kto.so` Malawski Akka @ Lightbend On 12 October 2017 at 00:27:11, bordec...@gmail.com (bordec...@gmail.com) wrote: Hi Konrad, I think, the above VERSIONS resolved my issue. Thank you very much for the response. I tested

Re: [akka-user] Implements CRDTs conters more than 100 000

It’s as the docs explain: It is not intended for *Big Data*. The number of top level entries should not exceed 10. When a new node is added to the cluster all these entries are transferred (gossiped) to the new node. The entries are split up in chunks and all existing nodes collaborate in the

Re: [akka-user] Re: Spray->Akka-Http Migration - seeing high 99th percentile latencies post-migration

Short lived connections are slightly more costly in Akka-HTTP than in Spray, due to the streaming infrastructure. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On October 17, 2017 at 9:48:20, Gary Malouf (malouf.g...@gmail.com) wrot

Re: [akka-user] Spray->Akka-Http Migration - seeing high 99th percentile latencies post-migration

Step 1 – don’t panic ;-) Step 2 – as I already asked for, please share actual details of the benchmarks. It is not good to discuss benchmarks without any insight into what / how exactly you’re measuring. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend

Re: [akka-user] Complete generate a null value in akka-http

Don’t return null in scala code, that’s very not-scala-style. Instead you could return empty things, or best rather even to throw an exception and make your handler https://doc.akka.io/docs/akka-http/current/scala/http/routing-dsl/exception-handling.html make it into a not found response. -- Chee

Re: [akka-user] No shutDown on Materializer

Hi Richard, Saying that “using Materializer” will cause leaks is somewhat of a weird phrasing, since that sounds just like “using ActorSystem can cause leaks” — well sure, just like “using objects can cause leaks” :-) Let’s step back and analyse where your colleague’s statement came from, and perh

Re: [akka-user] No shutDown on Materializer

fecycle method on Materializer vs ActorMaterializer? On Mon, Oct 23, 2017 at 7:39 PM, Konrad “ktoso” Malawski < konrad.malaw...@lightbend.com> wrote: > Hi Richard, > Saying that “using Materializer” will cause leaks is somewhat of a weird > phrasing, since that sounds just like “using Actor

Re: [akka-user] No shutDown on Materializer

4:07, Richard Rodseth (rrods...@gmail.com) wrote: Here you go https://github.com/akka/akka/issues/23837 On Mon, Oct 23, 2017 at 10:22 PM, Konrad “ktoso” Malawski < konrad.malaw...@lightbend.com> wrote: > Adding the shutdown method to the interface you mean? > I guess it could be conside

Re: [akka-user] Akka TCP and Slow Start Restart

That’s one of the reasons the new remoting is Aeron (and thus UDP, with TCP-like delivery semantics) based… :-) -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On October 24, 2017 at 3:59:30, Alan McSherry (alanmcshe...@gmail.com) wro

Re: [akka-user] Akka TCP and Slow Start Restart

What do you mean exactly? Switch to using Artery (the “new” remoting)? You could, sure. Just remember that it’s not encrypted so going over internet may be a bad idea if it has secure data. We’re working on a TLS-ed version of Artery, but it would likely be over TCP again. Though we know it shoul

Re: [akka-user] Akka cluster or Kubernetes

They’re completely different. Kubernetes is where you run apps. It shedules entire apps onto a set of nodes. Akka cluster IS the app. It runs on a set of nodes, and leverages health mechanisms to be able to smartly balance load and actors across them. Akka cluster apps are the apps that kubernete

Re: [akka-user] Akka TCP and Slow Start Restart

nection. I have a similar DDOS problem with Akka TCP but I know less about how friendly Akka remoting is to attackers. Ever come across someone using Akka remoting in an open internet type service...? On Wed, Oct 25, 2017 at 4:26 AM, Konrad “ktoso” Malawski < konrad.malaw...@lightbend.com>

Re: [akka-user] Timer of GroupedWithin (akka-stream-kafka) does not seem to be working

Please report in one space at the same time. This was already reported on the issue tracker by yourself. This is to avoid wasting cycles and time. Thanks. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On October 27, 2017 at 17:34:0

Re: [akka-user] ActorSystem FatalError Handling

When such errors are thrown all bets are off basically, in any app, not just akka. You can turn off the system automatically terminating — check reference.conf, though as I said — all bets are off then anyway because runtime is in potentially “bad state" -- Cheers, Konrad 'ktoso '

Re: [akka-user] ActorRef proxy - had somebody implemented?

Normally you’d simple have an Actor do this, instead of hacking into the internals as proposed in your snippet :-) Have an actor who’d keep messages and forward to the target once it’s received it. Having that said, we have the concept of such “FutureRef” defined and implemented in AkkaTyped, it’s

Re: [akka-user] Streaming proxy/tunel on top of akka-http

Akka-HTTP does support completely streaming things, that’s pretty much it’s main use case. Please share code and or specifics about what does not work. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On November 8, 2017 at 12:05:15, J

Re: [akka-user] FSMs and Akka Streams

Hi John, your problem description is a bit abstract so not quite sure what to advice there, however: please do bear in mind that Streams do not replace Actors. They complement them. Streams are nice for linear things, though Actors are nice for dynamic and distributed settings. It depends on your

Re: [akka-user] Older version of Akka framework

Hi Jani, Use your dependency management tool such as sbt, maven or gradle to download dependencies. They’re all hosted on maven central. No actively maintained version of Akka is compatible with JDK6. You can use a not-maintained version of 2.3.x though — though we strongly discourage that since i

Re: [akka-user] Android client connecting to Akka cluster via sockets

We’re working on an ClusterClient replacement that would use HTTP(2) or GRPC as it’s transport, this would be more or less what you’re after and also allow to keep the convenience of Actor messaging. I’d strongly discourage reverse engineering the protocol as such impl will be rather brittle, and

Re: [akka-user] Parsing Configuration

Hard to tell without knowing exactly what you’re doing there, but usually an explicit resolve is not needed. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On November 27, 2017 at 13:02:41, Joseph Mansigian ( joseph.c.mansig...@gmail

Re: [akka-user] Overriding onUpstreamFinish behaviour for FlowOps

What kind of Flow exactly. What does it do? See this too https://doc.akka.io/docs/akka/current/stream/stream-error.html?language=scala#delayed-restarts-with-a-backoff-stage other than supervision which isn’t generic. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Li

Re: [akka-user] Akka Typed and stack safety

That’d only be the case in completely synchronous execution. And the behaviours body would actually execute on that line — but it doesn’t. Here once you returned a new behaviour, control is given back to whoever is invoking things (in great simplification, “the actor system”). -- Cheers, Konrad '

Re: [akka-user] Akka persistence in production - recommended journals?

LevelDB is not, in any case, intended for production systems. Production ready journals would be: - the cassandra one, maintained by the akka team, it is most mature and has most features - the jdbc one, community maintained but seems to work well - we’ve heard of people using the mongo one, but I

Re: [akka-user] Akka Cluster Bootstrap ?

What do you want to know, that’s a pretty generic question ;-) We’re working on it. It works, it’s not done yet, will have to be cleaned-up quite a bit and documented. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On December 4, 201

Re: [akka-user] Last IntelliJ update (2017.3) breaks developing with Akka / Scala on Java

Hi Tomer, Thanks for reporting it to the IntelliJ team. Could you post a working link to the issue? The one posted does not seem to work. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On December 5, 2017 at 21:49:14, Tomer Rothschil

Re: [akka-user] Is it easy to use akka-http to build ...?

It’s pretty much as simple as using this directive: https://doc.akka.io/docs/akka-http/current/scala/http/routing-dsl/directives/file-and-resource-directives/getFromDirectory.html https://doc.akka.io/docs/akka-http/current/scala/http/routing-dsl/directives/file-and-resource-directives/getFromResou

Re: [akka-user] Re: How to measure performance of Actor Message from one actor reaching to another actor

Since you’d be measuring remoting there, on the boundary between nodes, I highly recommend making use of its “new” (has been out there quite a few months) implemenation: Artery, see docs here: https://doc.akka.io/docs/akka/2.4/scala/remoting-artery.html -- Cheers, Konrad 'ktoso ' M

  1   2   3   >