Hi all,

I recently migrate from Untyped actor to typed, but the Useful Test framework is not working anymore.

I cannot find any documentation of how to make works TestProbe and TestActorRefwith Akka actor Typed

Regards

The official Widgets Development Guide only contains the most basic widget types as example.

There is no functional example for a Flot chart in there right now. Or is it?

Since this is one of the most useful and probably used (at leat to me) widgets it would be very helpful to extend that docum

I'm new in Akka and trying to self-define a dispatcher in my code. But there are so few akka dotnet examples available, and most of them are using config files..
Could I create a dispatcher in code, i.e., like the follows:

public Dispatcher myDispatcher = new Dispatcher(new DispatcherConfigurator(ConfigurationFactory.ParseString(@"akka.actor.default-dispatcher { type = ""Akka.Dispatch.TaskDisp

Hi guys,

I'm a computer science student and I have to make a project in Go with Proto.Actor. Because of my lack of experience (this is my first project in Go, coming from Java) and the lack of documentation on the official website I find it very difficult to understand how one can use it. It would be nice if you could provide a better documentation. Thank you!

The idea is to be able to write the following to override the log configuration in dev-mode.

lagomDevSettings ++= Seq(
  "logger.resource" -> "logback-dev.xml"
)

https://github.com/paypal/squbs/blob/82ef1b1b6bf1f91cb64ba589554f22505a91a4d6/squbs-pipeline/src/main/scala/org/squbs/pipeline/RequestContext.scala#L48

This cast can fail. It is worrisome because a client would normally expect the Failure to be some kind of HTTP thing.

AFAIK, AKKA only has the Scala implementation for the Java-based abstract HttpResponse, but we should still address this

The Alpakka Kafka documentation should show how the classic KafkaConsumerActor is created when the user has a typed actor system.

Currently working with the AvroParquet module writing to S3, and I thought it would be nice to inject S3 configuration from application.conf to the AvroParquet as same as it is being done for alpakka-s3.

In such case, importing hadoop configuration would not be required, but optional.

In which being the original code for creating an avro parquet writer to S3 like:

val writer

Both have definitions for system that clash when used together as observed here.

Not sure what the best way forward is. Is there a 2.5/2.6 compatible way of testing typed actors?

hello world usage code

var props = Actor.FromProducer(() => new HelloActor());
var pid = Actor.Spawn(props);

but Actor code is like this

public static class Actor
{
    public static readonly Task Done;
    public static EventStream EventStream { get; }
}

so this code is not working at first.

[JVM-3] - must handle updates from different nodes *** FAILED ***
[JVM-3]   Set(LineItem [productId=1, title=Apples, quantity=7]) was not equal to Set(LineItem [productId=1, title=Apples, quantity=7], LineItem [productId=3, title=Bananas, quantity=4]) (ShoppingCartSpec.scala:91)
[JVM-2] - must handle updates from different nodes *** FAILED ***
[JVM-2]   Set(LineItem [productId=1, title=App

Here: https://github.com/cloudstateio/cloudstate#client-api

Akka HTTP releases are not tied to a particular Akka version (i.e. the 10.1.x HTTP releases are compatible with the 2.5.x Akka releases) and the user is responsible of providing the actual akka/akka-stream version to be used.

Since this library is mainly tied to a particular akka-http version, it would make sense to mark the other non http related dependencies as provided.

This way a user wa

So, I am a new user of Alka. I'm trying to learn. I've done the bootcamp, I've read some documentation.

Then, I come to this repo, which has the mission statement "to provide a small number of exceptionally well-explained and documented examples".

So I open up CrawlerService.cs.
First thing I noticed is that there are no code comments. At all.

So I read one of the first lines

protect

Hello,
I'm interested in using this project, but there are still some obscure undocumented aspects. The first one is the schedule method in the RefreshTokenStorage. Can you please clarify what is this for and how is it intended to be implemented?
Also the after parameter should probably be a FiniteDuration rather than simply Duration, should it not?
Is there a plan to work on some bet

Is it possible to share underlying KafkaConsumer thread or KafkaProducer thread among ConsumerActor and ProducerActor, respectively; similar to alpakka-kafka ?

Short description

In server-side
It should mention the HandlerFactory.
e.g
When do not using metadata, use GreeterServiceHandlerFactory.create().
When using metadata, use `GreeterServicePower

Looks like there is an issue with source links in https://doc.akka.io/api/akka-persistence-cassandra/0.103/akka/persistence/cassandra/ -- clicking on package.scala I get a 404: https://github.com/akka/akka-persistence-cassandra-1.x/tree/v0.103/core/src/main/scala/akka/persistence/cassandra/package.scala#L1.

Note the -1.x in the URL -- I guess it's from https://github.com/akka/akka-persist