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

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

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

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

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

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:

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

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] 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

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

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

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

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

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

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

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

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 —

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

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] 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

Re: [akka-user] yourkit CPU ignore list

.materialize? Or does that indicate a problem with the way play is setup? On 10 October 2017 at 10:49, Konrad “ktoso” Malawski <konrad.malaw...@lightbend.com> wrote: > ForkJoin noice mostly – people sometimes panic about ForkJoinPool#scan > specifically (which shows up when there’s nothing to

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

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)

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] 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

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

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 -

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] 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

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

>>> 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] 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

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

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

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

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] 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

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

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

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

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.

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

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

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

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

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] 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

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

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

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] 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 ->

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] [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

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

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,

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

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] 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

Re: [akka-user] No shutDown on Materializer

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 ActorSystem can caus

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)

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] 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 (

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

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 @

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 '

Re: [akka-user] cachingProhibited causes 404 not found to be returned by the server

Could you provide a small reproducer showcasing the issue as repo? -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On December 20, 2017 at 9:14:41, Nicolae Marasoiu ( nicolae.maras...@gmail.com) wrote: Hi, I have js files and a

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

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] 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,

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,

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] 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

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,

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

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

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

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> wrote: > What do you mean

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. --

Re: [akka-user] Akka Streams for synchronous request processing

Sure it’d just work… What specifically do you have in mind? What do you mean by “We should be able to plug-in out partial graphs to the flow.” (specifically, what’s the use case). -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On

Re: [akka-user] Akka Streams for synchronous request processing

In short I want to execute Akka graph from my API with out materializing every time. What’s your reason for this? Just so we’re on the same page and not imagining reasons for doing this :) Problem that I am facing: How to pass request object to source node of graph. That’s as simple as using a

Re: [akka-user][deprecated] Akka streams doesnt run when integer range is large

This was already answered on stackoverflow; https://stackoverflow.com/questions/50264569/akka-streams-doesnt-run-when-integer-range-is-large You likely terminate the app before the stream has time to print all things — you have to wait for that to happen as mentioned on SO, this is done by using

Re: [akka-user][deprecated] [Akka 2.5.x][Remoting] - Recovering from guaranteed nodes

Could I ask you to move the question to discuss.akka.io? Thanks! -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On May 17, 2018 at 18:26:11, gutzeit (gutz...@gmail.com) wrote: Dear list members, My company runs a large scale

Re: [akka-user][deprecated] How to generate the javadoc for offline use?

Hi there, It’s `sbt Dakka.genjavadoc.enabled=true doc` if I remember correctly. I suggest you ask questions on the https://discuss.akka.io forum as that one we monitor more actively nowadays (as mentioned in the footer and header of the mailing list) -- Cheers, Konrad 'ktoso '

Re: [akka-user][deprecated] Akka Streams Resuming Materializer does not log exceptions

Use the .log() operator. Same as exceptions thrown in a Future do not automatically get logged. There has been discussion about enabling this always, however you’d then be swamped with errors which are recovered and actually “fine and nothing to worry about”. If you want logging, put a log()

Re: [akka-user][deprecated] Caused by: com.typesafe.config.ConfigException$Missing: No configuration setting found for key 'enabled'

It is likely related to your build or code, please share that. Can we continue this on discuss.akka.io please though? You have a better chance to get answers quickly there. As noted in the header of this mailing list: We announced

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

Re: [akka-user] access to http response databytes stream materialized value

data= data.mapMaterializedValue(mat => doThings(mat)) Is how you can achieve it. Yes, it’s the current best practice in those situations. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On December 30, 2017 at

Re: [akka-user] alpakka version of "Producer" or "Consumer" object?

Hi Soichi, “Producer” and “Consumer” are words used in Kafka, as such Alpakka’s Kafka integration uses them as well. (Note that Akka-Steam-Kafka is part of Alpakka, even if in an separate repository) The prime idea in all Alpakka things is that there are Sources (i.e. the Consumer (consumes from

Re: [akka-user] Akka 2.5.8 (Java Edition) Error initializing: java.lang.IllegalStateException: not yet initialized

Are you not accidentally mixing Akka versions? What does your dependency file look like with regards to Akka dependencies. Akka Streams and Actor etc should all be on the same version. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend

Re: [akka-user] expectNoMessage keeps unexpected message in the queue

What do you mean? What queue? They are both implemented using the exact same internal method: @deprecated(message = "Use expectNoMessage instead", since = "2.5.5") def expectNoMsg(max: FiniteDuration) { expectNoMsg_internal(max.dilated) } /** * Assert that no message is received for the

Re: [akka-user] Processing `If-None-Match`

You can deconstruct the data structure on your own like this: val tag = EntityTag("kappa", weak = true) val ifNoneMatch = `If-None-Match`(tag) ifNoneMatch.m match { case EntityTagRange.Default(tags) if tags.nonEmpty ⇒ tags.head.tag case EntityTagRange.Default(tags) ⇒ "" case

Re: [akka-user] File based durable mailboxes for akka actors

Seems Durable (filebased) mailboxes weren’t even in 2.3, but 2.2… So even more ancient ;-) A question regarding them, made me assume you’re using those ancient version of Akka. Please give Persistence a try. There’s nothing durable mailboxes did better (or even as good as) Persistence does

Re: [akka-user] expectNoMessage keeps unexpected message in the queue

I see! Thanks for digging that up. I think that was an un-intended change so I’ll fix that right away. Issue here https://github.com/akka/akka/issues/24270 PR soon. -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On January 8, 2018

Re: [akka-user] alpakka version of "Producer" or "Consumer" object?

1. alpakka kinesis connector works well with KPL as well as KCL It uses import com.amazonaws.services.kinesis.AmazonKinesisAsync KPL seems to be the “kinesis data streams” api? That seems to use the same PutRecord etc logic as we do though. 2. KinesisSources and KinesisSinks both work as

[akka-user] Re: decorate actor events / events processing as a way to implement open tracing capabilities

Hi there Daz, I would strongly recommend using a proven implementation of tracing, i.e. the Lightbend Monitoring stack and it's Open Tracing support: https://developer.lightbend.com/docs/monitoring/latest/extensions/opentracing.html Implementing it manually may seem like doable or at first, but

Re: [akka-user] akka-http remote to akka cluster or join the cluster?

Using the cluster client is not recommended (as of it’s current implementation at least, in early 2018 ;-)). You can absolutely join your HTTP app into the same cluster and then most apps make use of Cluster Sharding to distribute the load across the cluster. Read up about it here;

Re: [akka-user] Cancel Actor job

Actors may not be that cheap. They are ~400 bytes for an Actor; plus whatever you put inside one of course, but that’s your state, not the Actor’s fault ;) I tried to create a worker actor every time the master actor received a start job message and found out that it created a new thread to run

Re: [akka-user] Akka, Akka Typed and dead code elimination

Hi Christopher, I’ve worked in the past on an Scala on Android project, so have had the “pleasure” of battling proguard for similar reasons. In general I guess the “core stuff” needs to be kept, which would mostly be the akka.actor and dungeon things. AFAIR proguard is ale to understand

<    1   2   3   >