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
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
amine.chikhaoui
@amine.chikhaoui:matrix.org
[m]
Hi everybody, I'm experimenting with Akka + Play framework for the first time and have some questions. For example say I have a web service endpoint /doAction which I want to use in a hybrid mode in terms of consistency. It would do a write to a database + send a message to a Kafka topic for consumption by downstream systems. The request from the client would return as soon as the database write is done and the rest is eventually consistent. My confusion is how to make sure that this process is atomic i.e what if the app crashes halfway through (between the database update and sending the kafka message)
3 replies
Amine Chikhaoui
@amine.chikhaoui:matrix.org
[m]
@leviramsey: by Persistence Query/Projections you mean queries of the events journal ?
2 replies
Amine Chikhaoui
@amine.chikhaoui:matrix.org
[m]
got it @leviramsey though if the actor that writes to the DB is persistent, isn't that not recommended ? As I would imagine the Actor would persist the incoming event and then write to the database in the callback, but if the event is replayed for any reason that would attempt another write to the DB ?
my understanding of akka terminology is still basic so I might be saying nonsense :p
Levi Ramsey
@leviramsey
It's a little unorthodox for an actor to query it's own events... the more normal approach would be to have another actor querying the event stream
1 reply
Amine Chikhaoui
@amine.chikhaoui:matrix.org
[m]
oh the persist callback can side effect ? but isn't that the same thing that gets called during replay
btw the persistent actor in my case wouldn't have any state, I can't think of a state that I can keep
Levi Ramsey
@leviramsey
No, only the event handler is called during replay, so it should be pure
Amine Chikhaoui
@amine.chikhaoui:matrix.org
[m]
as the state is kept in the DB basically
hm got it, I had a confusion and thought the event handler is both called during replay and in the persist callback
Levi Ramsey
@leviramsey
The event handler will typically get called (and does automatically in typed) in the persist cycle, thus why you shouldn't side effect there, but the callback only gets called on successful persistence of events
Amine Chikhaoui
@amine.chikhaoui:matrix.org
[m]
and it's not very odd if I use a persistent actor but without any state basically ?
Levi Ramsey
@leviramsey
Well it kind of will have state: things that should be published to Kafka but haven't yet been
(in which case the persistence query may well just be to find out which persistent actors need to be woken up to publish to Kafka)
Amine Chikhaoui
@amine.chikhaoui:matrix.org
[m]
but that's more of the state kept in the events journal right ? not the actor state itself
hmm I was thinking the query would be against the journal
but maybe you mean the query is against the persistent actors state ?
Levi Ramsey
@leviramsey
@amine.chikhaoui:matrix.org I'll have to go away from keyboard for a little while before continuing
Amine Chikhaoui
@amine.chikhaoui:matrix.org
[m]
oh it's indeed the journal from reading https://doc.akka.io/docs/akka/current/persistence-query.html
@leviramsey: sure thanks a lot of the patience with my questions :)
Swoorup Joshi
@Swoorup
should I use actorselection or just pass actorRef?
6 replies