All Questions
5,067
questions
1
vote
0
answers
48
views
Akka to Pekko Migration and Grpc
Heeey all,
I'm doing a Akka to Pekko migration of a pet project (I'm learning scala atm). So far everything went smooth but there is one thing that I can't get fixed and the grpc plugin.
In my build....
- 374
1
vote
0
answers
34
views
HTTP connection closed unexpectedly issue in akka-stream application
In my akka-streams(scala) application, I am using google pubsub as the source, querying from a BigQuery table and then publishing an outcome to a kafka topic and later acknowledging the pubsub
message....
- 11
1
vote
1
answer
128
views
List of Future is not executed in parallel
I don't understand why this code is not executed in parallel.
implicit val ec: ExecutionContext = system.dispatchers.lookup("db-non-blocking")
println(s"Cores ${Runtime.getRuntime()....
- 103
0
votes
0
answers
65
views
Flink Actor not found for: ActorSelection[Anchor(pekko://flink/deadLetters), Path(/)]
On my kubernetes cluster I have flink-kubernetes-operator 1.7.0 and apache-flink 1.18.1 installed. I came across an issue when I installed FlinkDeployment CR (custom resrouce) into a namespace named ...
0
votes
0
answers
66
views
java.lang.IllegalStateException Sink.asPublisher(fanout = false) only supports one subscriber when using custom Playframework body parser as stream
After looking around stackoverflow and github issues, it seems this happened several times already in different contexts but never received any real help nor solutions so I try my luck once again.
We ...
- 514
0
votes
1
answer
54
views
Scala Akka Http : com.typesafe.config.ConfigException$Missing: No configuration setting found for key 'dispatcher'
Creating API using scala Akka, code is running in IDE but when jar is created not able to run the code:
usind scala 2.11.12 and Below is build.sbt
ThisBuild / version := "0.1.0-SNAPSHOT"
...
- 35
0
votes
1
answer
38
views
Using Akka GraphDSL with Zip stages
Consider the following code:
GraphDSL.create() { implicit builder =>
import GraphDSL.Implicits._
val in = Source(0 to 10)
val fanOut = builder.add(Broadcast[Int](2))
val toString = builder....
- 13.3k
0
votes
1
answer
58
views
Await.result always hangs/timeout and never returns result (Scala - Akka actors)
To make an inefficient story short, I am trying to make a Scala actor system which computes Fibonacci numbers. However, the Await.result() lines always timeout, and I'm not sure what the issue is.
...
0
votes
1
answer
65
views
Optimizing CPU Utilization and Throughput in Akka / Pekko Streams on HTTP
Consider the following code:
def getFlow()(implicit appConfig: AppConfig, actorSystem: ActorSystem): Flow[BrandSafetyServiceRequest, HttpResponse, NotUsed] = {
implicit val ...
- 1,102
0
votes
0
answers
17
views
Handling of WebSocket Client Messages in Play Framework
I have a case where my client opens a WebSocket connection upon which I subscribe to a MQTT topic and fetch the messages that I need to publish to this client. It could be that in-between the client ...
- 14.9k
0
votes
0
answers
25
views
akka PubSub not working across distributed system
I have a system that is clustered deploy on k8s, it will have multiple instances when it's deployed.
My code sample like below
import akka.actor.typed.pubsub.Topic
import akka.actor.typed.scaladsl....
1
vote
0
answers
21
views
Handling WebSocket Connections in Play Framework
I have a case where I need to re-use already open connections to a client and for this I'm storing the connections as soon as they are opened in a ConcurrentHashMap and when the server needs to send ...
- 14.9k
0
votes
0
answers
22
views
akka stream merge data from multiple replicas system
I have two systems, let's refer to them as SystemA and SystemB, both deployed on a Kubernetes (k8s) cluster. SystemA is deployed with two replicas, namely SystemA-1 and SystemA-2, while SystemB has ...
0
votes
2
answers
106
views
Akka Streams: How to construct a Source of Sources with GraphDSL?
Here's a simple scenario.
Let's begin with a single Akka Source: let's say, of rows retrieved from a database. Based on a partitioning function, different rows need to be diverted into different ...
- 812
0
votes
1
answer
48
views
Skip flow on failure akka streams
I wan't to skip a flow without losing the data that was sent in case of failure. But I can't found a way to do that. Here is an example code that I being using to test.
val decider: Supervision....
