Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
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 25 2020 16:21
    nitikagarw commented #25468
  • 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
  • Oct 24 2020 20:31
    akka-ci labeled #29672
  • Oct 24 2020 20:26
    dope9967 synchronize #29672
  • Oct 23 2020 16:16
    ennru demilestoned #24444
  • Oct 23 2020 16:16
    ennru reopened #24444
  • Oct 23 2020 16:16
    ennru commented #24444
Johan Andrén
@johanandren
If you are on MacOS I think we can share a template keynote doc to start from/copy paste shapes colours etc.
1 reply
Patrik Nordwall
@patriknw
New Akka team plan akka/akka-meta#147
Nitika Agarwal
@nitikagarw
Hi team, Please review: akka/akka#29913
Johan Andrén
@johanandren
FYI @nitikagarw a second improvement on top of your "include name in graphstage logic toString” that adds a source location, file and line, for operators that takes a lambda parameter got merged yesterday: akka/akka#29935
1 reply
@naderghanbari here you go (couldn’t drop file in gitter thread for some reason)
kerr
@hepin1989
@johanandren cool, thanks for sharing
kerr
@hepin1989
kerr
@hepin1989
Orleans just add this, seems interesting https://github.com/dotnet/orleans/releases/tag/v3.4.0
Patrik Nordwall
@patriknw
Thanks for sharing. I’m very aware of lifeguard, but not enough problems reported with current Akka Cluster and many other things have higher priority.
Johan Andrén
@johanandren
Akka HTTP 10.2.3 release in progress
kerr
@hepin1989
https://doc.akka.io/docs/akka/current/persistence-journals.html
Is well designed and can be implemented on lindorm(https://help.aliyun.com/product/172543.html
)'s internal stream model.
Seems I can take advantage of the storage if it supports row-level TTL.
2 replies
Johan Andrén
@johanandren
Nitika Agarwal
@nitikagarw
Hi team,
I am working on akka/akka-http#2648 and I need a little help here: https://github.com/akka/akka-http/pull/3739#issuecomment-762349807
Nitika Agarwal
@nitikagarw
PR for updating current year in CopyrightHeader: akka/akka-http#3750
Patrik Nordwall
@patriknw
New Akka team plan akka/akka-meta#148
kerr
@hepin1989
@patriknw it's linked to itself in the previous plan
Conor Griffin
@conorgriffin
Is it possible to re-trigger the typesafe-cla-validator on a PR? - akka/alpakka#2567
1 reply
Nitika Agarwal
@nitikagarw
Team please review: akka/akka-http#3739
Harish
@harishmca_twitter
Hi Team, I am trying to run Alpakka sample to read CSV and publish to Kafka but program stuck with start point only. Please could someone help here
Johan Andrén
@johanandren
@harishmca_twitter this is the channel for us who develop Akka and umbrella projects, for questions about using Akka/Alpakka etc. please use the akka/akka channel.
Henry Story
@bfish:matrix.org
[m]
I had a question on akka/akka regarding the APIs on http headers being a bit too sealed. To do it right I'd end up having to become a dev, and fork akka.
Johan Andrén
@johanandren
Go ahead and ask :)
VarunVats9
@VarunVats9
Hi, one query, let's suppose we have multiple flows attached one after another, so should we have supervision strategy attached with each flow ? Or its okay to have only one on the main flow ?
Johan Andrén
@johanandren
Hi @VarunVats9 this is the channel for us who develop Akka, please use the akka/akka channel for questions about using Akka
VarunVats9
@VarunVats9
Sure @johanandren
Abbey
@Casperlet
Hi, I'm reading Akka Platform guide. I get a question about CQRS. Why should entity ShoppingCart have a command "Get"? I think "Get" is a query method, so it should move into read model.
I think CQRS is a pattern, not architecture. So, it fits for one BC, not the whole system. Anything external wants to get the entity state, it should ask the read model, not the write model. But the guide shows the entity ShoppingCart returns its state by the command "Get".
Abbey
@Casperlet
In CQRS, command in the write model changes the state of entity, triggers some events, but returns nothing. query in the read model asks the entity to get replies, but changes nothing. Entity gets eventually consistent by read model consuming the events published from write model.
Levi Ramsey
@leviramsey
This is a channel for coordinating the development process of Akka itself. akka/akka is the channel for questions like yours around developing using Akka.
Abbey
@Casperlet
@leviramsey sorry. I get it. thank you.
Sean Glover
@seglo
hello everyone. just a heads up that we're planning to release Alpakka 3.0.0-M1 in the next day or so.
Conor Griffin
@conorgriffin
🎉
Derek P. Moore
@derekm

FYI -- Olivier Nouguier is presenting about his Pravega Alpakka connector tomorrow at our monthly Pravega.io meetup: https://community.cncf.io/events/details/cncf-pravega-community-presents-pravega-community-meeting-1/

Olivier currently has a new PR open to Alpakka to add Pravega Key-Value Tables support to his Akka connector: akka/alpakka#2651 ... I believe he plans to discuss this latest work also.

Seeta Ramayya
@Seetaramayya

Hello Alpakka team,

When I am trying to build docs/previewSite locally in my computer for alpakka, I am getting following error messages

  • google-cloud-pub-sub-grpc/src/main/protobuf: warning: directory does not exist.
  • google-cloud-pub-sub-grpc/src/main/proto: warning: directory does not exist.
  • google-common/src/main/protobuf: warning: directory does not exist.

What am I doing wrong? From where can I get these proto files

raboof
@raboof:matrix.org
[m]
@Seetaramayya: those warnings are harmless: the plugin can pick up proto files from those directories, but doesn't, since this project takes the proto files from a dependency jar. it's just a bit loud about it.
1 reply
Seeta Ramayya
@Seetaramayya
image.png
Alpakka slick documentation still pointing to external link that looks like slick.lightbend.com which gives big warning in the browser if I click the link. When I generate the documentation locally it is resolving correctly. I think the base urls are changed in Dec (maybe those are not yet deployed, this is the wild guess )
pruthvi578
@pruthvi578
I get empty data while reading response entity sometimes. But able to manually get information using curl. Is there an error handling mechanism to ensure that we receive data from response entity in akka http client?
raboof
@raboof:matrix.org
[m]
@pruthvi578: this channel is about developing akka, not developing with akka - akka/akka would probably be a better place for your question. Do you check the response status code?
@pruthvi578: ah I see you have ;). let's keep it there.
Sean Glover
@seglo
I'm going to release Alpakka 3.0.0 and Alpakka Kafka 2.1.0 finals by the end of this week.
arvkonstantin
@arvkonstantin
Hello! I deal with akka streams, I try to mock the repository interface, make an in memory implementation. I have a collection of case classes case class Command(UUID: UUID, var done: Boolean), it is constantly updated, it is a source, I need to use akka streams to constantly search for done = = false in it and change to true. I tried different methods, such as Source.repeat. On the Internet, too, I did not find such a thing, I will be glad of your advice, thank you
raboof
@raboof:matrix.org
[m]
@arvkonstantin: I'm not sure I understand what you're trying to do, but it sounds like you are working 'with' akka rather than 'on' akka, right? in that case the akka/akka room might be more suitable. What 'repository interface' are you mocking?
arvkonstantin
@arvkonstantin
@raboof:matrix.org Yes, you're right, I messed up the chat, but it looks like I found what I need - https://developer.lightbend.com/start/?group=akka&project=akka-samples-persistence-scala
Jaroslav Regec
@sviezypan
hi all, I am trying akka microservices tutorial and I am having troubles installing akka cloud platform on gke, here in point 1 https://developer.lightbend.com/docs/akka-platform-guide/deployment/gcp-install.html#_deploy_from_command_line
"Generate a license key and save it to the disk (e.g. license.yaml)." Can you point me to the direction what is license.yaml referring to? Its not mentioned anywhere before, neither is there any link
6 replies
Enno Runne
@ennru
I hope to get around and release Alpakka 3.0.1 tomorrow. akka/alpakka#2682
Jacek Sokol
@jaceksokol
Hello, for some time I was missing a possibility to process messages in akka stream in parallel but only within a "partition". I couldn't find a solution for my problem so I wrote a custom operator: https://github.com/jaceksokol/akka-stream-map-async-partition. My question is if it possible to achieve a similar processing pipeline using existing operators/graph dsl?
Johan Andrén
@johanandren
Not entirely sure I when your custom operator is expected to emit, but I think it is something in the neighbourhood of groupBy(somenumber ,extractPartition).mapAsync(parallelism).mergeSubstreams()
2 replies