Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Oct 26 2020 07:39
    patriknw labeled #29767
  • Oct 26 2020 07:39
    patriknw labeled #29767
  • Oct 26 2020 07:39
    patriknw labeled #29767
  • Oct 26 2020 07:39
    patriknw labeled #29767
  • Oct 26 2020 07:38
    patriknw commented #29767
  • Oct 26 2020 07:07
    patriknw commented #29765
  • Oct 26 2020 06:56
    patriknw commented #25468
  • Oct 26 2020 06:30
    wtfiwtz starred akka/akka
  • Oct 26 2020 04:31
    YunSeongKim7 starred akka/akka
  • Oct 25 2020 16:21
    nitikagarw commented #25468
  • Oct 25 2020 09:22
    fubiao starred akka/akka
  • Oct 25 2020 05:09
    saguywalker starred akka/akka
  • Oct 24 2020 21:47
    tt4n starred akka/akka
  • Oct 24 2020 21:20
    akka-ci commented #29672
  • Oct 24 2020 21:05
    dope9967 commented #29672
  • Oct 24 2020 21:03
    akka-ci commented #29672
  • Oct 24 2020 21:03
    akka-ci unlabeled #29672
  • Oct 24 2020 21:03
    akka-ci labeled #29672
  • Oct 24 2020 20:44
    dope9967 synchronize #29672
  • Oct 24 2020 20:31
    akka-ci unlabeled #29672
raboof
@raboof:matrix.org
[m]
@brabo-hi: I don't think so, because I think ~ waits for the command to finish, and run doesn't finish. It sounds like you're looking for https://github.com/spray/sbt-revolver
brabo-hi
@brabo-hi
@raboof:matrix.org thank you for your help
Gaël Jourdan-Weil
@gaeljw
Hi folks,
I opened a question on SO about being able to "detect" a Source failure at startup => https://stackoverflow.com/questions/67467565/play-framework-akka-streams-intercept-errors-at-source-startup
I was wondering if anyone here would have any idea on the subject. Any help appreciated, thanks :)
Didac
@umbreak

Hi. I came up with the following benchmark on GRPC: https://github.com/LesnyRumcajs/grpc_bench/wiki/2021-04-13-bench-results

akka-http (using akka streams) rates very low on the benchmark. It could very well be on the nature of the benchmark (if that’s the, could someone point out what to change on the scala side to improve it). If it is not, what could be done to address the performance issues? Is that on the scalapb side, on the akka-http side or on the akka-streams side?

4 replies
bblfish
@bblfish:matrix.org
[m]

It is an antipattern to have state that crosses an actor right?
But is it really problematic to have a isStale function

class DataMessage(data: Stuct) { 
   def isStale: Boolean ...
}

where the actor that sends out the message can set its DataMessage to stale, letting any other actor on the same JVM know to fetch a new one.

1 reply
Alex Klibisz
@alexklibisz
Hi all, I have a question about the Uri model. Is there a way to add query parameters to a Uri which already has some query parameters? Calling .withQuery seems to replace the existing query parameters. So far the best I've found is to extract the original query, convert it to a Map, concatenate the Map with a Map of new params, and then pass the concatenated map to .withQuery.
2 replies
Ceyhun Can Ulker
@ciuncan
Hi,
Isn't shutdown applied to each materialized akka stream when the actor system initiates coordinated shutdown? I can see that the task I added to coordinated shutdown being executed (logs) but I don't see the logs I added to Sink.onComplete and also via .watchTermination on the stream. If I trigger a kill-switch in the coordinated shutdown task I registered, I see logs in both from Sink.onComplete and .watchTermination. So do I have to always use a kill-switch for such infinitely running streams?
2 replies
Zhenhao Li
@Zhen-hao
hi, my serializer implemented ByteBufferSerializer but Akka still uses the se/de methods with byte arrays. do I need to change anything in the config?
2 replies
Zhenhao Li
@Zhen-hao
I have Exception in thread "main" java.nio.file.AccessDeniedException. but my aeron-dir has been created and owned by my app user. what can cause this error?
Sathish
@Sathis

Hi, I Downloaded akka sample project in github for using multi-jvm.
I get the following sbt error when the project is imported. My machine is not behind proxy. Do i need to add the cert to default trustore of JVM to fix this issue?

https://github.com/akka/akka-samples/tree/2.6/akka-sample-cluster-scala

unable to find valid certification path to requested target) while downloading https://repo.scala-sbt.org/scalasbt/sbt-plugin-releases/com.typesafe.sbt/sbt-multi-jvm/scala_2.12/sbt_1.0/0.4.0/ivys/ivy.xml
unable to find valid certification path to requested target) while downloading https://repo.typesafe.com/typesafe/ivy-releases/com.typesafe.sbt/sbt-multi-jvm/scala_2.12/sbt_1.0/0.4.0/ivys/ivy.xml

Jeff May
@jeffmay
is there anyway to catch the InterruptedException so that I can terminate the actor system and prevent it from running in the background of sbt? I am trying to avoid forking the JVM, but maybe that is the wrong approach?
Enno Runne
@ennru
Mr. Follower
@MrFollo49718686_twitter

hi all

spray has been replaced with akka http, but is spray json here to stay? what is its future?

Mr. Follower
@MrFollo49718686_twitter
we are using akka-http-spray-json but since it has spray in the name the question is whether this library is going to be supported
michalbogacz
@michalbogacz
Hello, I have quick question for akka-persistence-jdbc, shouldn't fromSequenceNr be used for finding highestSequenceNrForPersistenceId in https://github.com/akka/akka-persistence-jdbc/blob/master/core/src/main/scala/akka/persistence/jdbc/journal/dao/DefaultJournalDao.scala#L61 ?
raboof
@raboof:matrix.org
[m]
@MrFollo49718686_twitter: we don't have any plans to replace spray-json
Mr. Follower
@MrFollo49718686_twitter
thank you, @raboof:matrix.org
Jake Zhang
@Kiddinglife
Hey I am wondering if it is liekly to have different trasnport implementations for the actors? for example, some actors uses udp protocol and some other use tcp. I kenw this can be easily done by running two actor systems with udp and tcp transport repectively. but can we do the same thing with an single actor system ? thank you.
Chetan Kokil
@chetankokil
Does any one have E2E example using Akka http, Actors and database ?
Zhenhao Li
@Zhen-hao
@chetankokil have you checked https://github.com/akka/akka-samples?
3 replies
Patrik Nordwall
@patriknw
@Kiddinglife that is not supported, only one transport per ActorSystem is supported.
2 replies
Swoorup Joshi
@Swoorup
Will Akka support any of the scala 3 features natively?
4 replies
brabo-hi
@brabo-hi
Hi all, i have an actor where for each exetrnal message, will send 5 messages serially to self (for example when talking to external services). When updating the node on kubernetes, how to continue processing internal messages for each actor from where it stopped on the previous node?
6 replies
DiscworldZA
@DiscworldZA
Hi I am having trouble closing a flow properly on handleWebSocketMessages, it seems on failure the handler crashes and refuses to open again?
3 replies
Zhenhao Li
@Zhen-hao
hi, this is for everyone. I'm willing to pay up to 300 Euro per hour because this is giving me a lot of issues in production. https://pairtime.com/post-by/WVMA3PXxTXHM7tjF71Y-2qjkCHi1rzEie6kzwR0p2VVSDan4tb7JjhuinsgluaDqQRZZs-P4oKoX5BHNKuFMUBflKQUVdwg=
3 replies
Maksym Vorobey
@Max161
If you were to use the hexagonal architecture, known also as Ports & Adapters if your web server was a Play framework would you put an Akka Actors layer between the controller layer and the application one? For example, as represented here: https://ibb.co/N3vGDb4
Or it's only adding complexity to the application? In such a situation the controller would send a message to an Actor, that would execute a particular use case...
brabo-hi
@brabo-hi
Hi, where can we get lagom roadmap ?
Sathish
@Sathis

Hi, I'm trying to create a akka streaming application consuming data from Fixed length file.
We are using BeanIO Java Blocking library to Serialize and Deserialize Fixed length file.

BeanIO library exposes read operation, which reads one line at a time.
I'm planning to create akka Source out of this and then have rest of the processing Graph.

So the Code.. will look like this..

Source.fromIterator(() => fromIterator())
.withAttributes(Attributes(ActorAttributes.IODispatcher))
    .runForEach(println)

val fromIterator =  new Iterator[AnyRef] {
var record = ??? // Something we can't avoid
 def next(): AnyRef = ???

 def hasNext(): Boolean = ???
 }

Iterator implementation looks simple, but it will use var variable to maintain state.

Is this the better approach or create an Graph for consuming record from BeanIO and then use

Source.fromGraph(....)

3 replies
Bernhard Huemer
@bhuemer
Hi! I am trying to implement client-side NTLM authentication with Akka HTTP, and it's sort of working already (pulled out NtlmEngine from Apache HttpComponents for the messages) - however, there's one issue: I'm not sure how to identify which connection a request is using. Authorization works, but at the moment I cannot rely on persistent authorizations, because I don't know how to identify the connection I'm using, and otherwise the authorizations might leak across.
2 replies
Jake Zhang
@Kiddinglife
A newbie question. Can I use Artery with akka http and akka grpc? thank you.
Eric Chung
@ericccw
Hello, I'm new to akka. May I ask is there any way to find the implementation of @InternalStableApi
def sendMessage(msg: Envelope): Unit
3 replies
raboof
@raboof:matrix.org
[m]
@Kiddinglife: you can use Artery in the same Akka application as you use Akka HTTP or Akka GRPC, but they don't build on each other
1 reply
raboof
@raboof:matrix.org
[m]
@Kiddinglife: Akka HTTP doesn't use Artery and Artery doesn't use Akka HTTP, they're independent
10 replies
Domantas Petrauskas
@ptrdom
Hi, looking at Akka Persistence Cassandra source, it seems that UNLOGGED batches are used everywhere - journal, snapshots, tag writes, and those aren't atomic, at least for cross-partition batches, which are allowed by the plugin. Isn't this an issue then, making Cassandra plugin not conforming to Akka Persistence API?
1 reply
Damien O'Reilly
@DamienOReilly
Hi, what is the recommended approach to adding request timeouts to an akka-http client?
I have tried to add a completionTimeout and an idleTimeout on an SourceQueueWithComplete that processes the requests, however I am not seeing any long running requests timeout.
1 reply
vakhtang
@vakhtang
The Alpakka SQS connector periodically fails with TCP idle-timeout encountered on connection to [sqs.us-east-1.amazonaws.com:443], no bytes passed in the last 1 minute. What's the recommended way of handling this error? Increasing the timeout seems like one solution, but it's not clear what a reasonable value should be (also this is a global setting), or why the Alpakka SQS connector isn't self-healing in this respect. Any advice?
Enno Runne
@ennru
Daniel LaFlamme
@dlaflamme
Could someone point me to the best practice for how to set up a develop environment for alpakka and also one of its dependencies? What I am doing specifically is making changes to akka-stream-alpakka-ftp and also to its direct dependency, sshj. sshj builds with gradle and alpakka builds with sbt. What is the correct way to point the alpakka build to pick up the changes I am making to sshj?
1 reply
Alexandre DUVAL
@KannarFr
Hi, is it possible to write an akka-http PathMatcher that directly matches to Refined item?
Daniel LaFlamme
@dlaflamme
question on one of the alpakka examples. This line of the ftp-to-file example, https://github.com/akka/alpakka-samples/blob/master/alpakka-sample-ftp-to-file/src/main/scala/samples/scaladsl/Main.scala#L57, writes the remote file to a file on the local host. what is the best practices way to do this, AND do something to the local file--such as set its last modified time to the same as the file on the remote server? this is a question of how to structure the streams pipeline, not specifically how to set the modification time. ideally, you want the file to be downloaded successfully before attempting to do something to it...
1 reply
Max
@maxstreese
Hi! got a question about EventSourcedBehavior: What if I got an actor that besides having some state to be persisted, I also want to contain regular old actor state which shall be forgotten as soon as the actor stops? To give as an example the case I am envisioning: I have the stateful actor consume some commands that should sometimes mutate the state and sometimes also broadcast some messages based off of the state to some set of subscribing actors. I am sure I am just not seing something but as you are not supposed to mix EventSourcedBehavior with any other behavior I am having difficulties. So what's the established way of doing this? Can I mark some fields of my state as not to be persisted or something?
7 replies
Swoorup Joshi
@Swoorup
does anyone even use NotUsed, Done instead of Unit or something else in scala?
why not simplify the api in scala
Andreas Flierl
@asflierl
I use that all the time. Unit is very dangerous.
Swoorup Joshi
@Swoorup
Why is it dangerous?
raboof
@raboof:matrix.org
[m]
I'm not sure I'd say 'dangerous', but I like having specifically-named object types to describe things rather than just getting Unit
Swoorup Joshi
@Swoorup
Ok so Done is used with Future[Done] but what about NotUsed? Seems like perfect fit to replace with Unit
Levi Ramsey
@leviramsey
Semantically every immutable singleton is a perfect fit to replace with Unit.
If things have different interpretations they should be named differently.
lynxpluto
@lynxpluto
Hi everyone! Is it possible to run Akka Projection on a single node cluster for dev/debug purposes?
1 reply