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
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
Joost de Vries
@joost-de-vries
I spoke to Arnout about providing a Akka actor helper library for Kotlin. It would be a thin lib that improves Akka actors Java api for Kotlin developers. Make it feel native Kotlin if possible.
I understood from him that a community maintained repo would be the best approach.
I think I'll start one under my personal github account. And when ready perhaps it can be under the Akka org.
I'll create an issue under that repo to describe the approach, the goals and non goals. So you can weigh in if you want.
2 replies
Joost de Vries
@joost-de-vries
Btw here's a little experiment what Akka actors could look like using Kotlin coroutine channels. https://github.com/joost-de-vries/akka-kotlin/blob/master/src/main/kotlin/akka/kotlin/classic/example4/channelInbox.kt
That won't be part of the lib. But still fun to have a look at. I recommend opening it in IntelliJ since that presents suspend calls and implicit this types more clearly.
Patrik Nordwall
@patriknw
@joost-de-vries cool, thanks for making this Kotlin support library.
Arnaud Burlet
@fredfp
@patriknw Hello, about akka/akka#30362 do you know which specific loggers you'd like? I have no way to export logs so if the volume is not too big that's doable, otherwise I could only offer a pairing session to share logs live.
1 reply
Josep Prat
@jlprat
Hi there!
I was reading the docs about Sink.combine and found out the Scala example was not printed. Submitted a fix for it: akka/akka#30433
raboof
@raboof:matrix.org
[m]
Thanks! Don't worry about the failure: we're trying out GH Actions and are seeing some instabilities there
1 reply
Josep Prat
@jlprat
it can't be re-triggered with the PLS BUILD right?
raboof
@raboof:matrix.org
[m]
no the PLS BUILD is only picked up by Jenkins - I can rebuild from the GHA UI but not sure it's worth it yet ;)
Josep Prat
@jlprat
oh no worries! I was exercising my muscle memory :)
but I realized as you said that github actions won't pick it
cmamedzade
@cmamedzade
I there!
I want to contribute Akka project. So picked akka/akka#29776 this issue for first step. But it is hard to me for first time. Who can help about it?
3 replies
Aditya Gupta
@Aditya-Gupta1
Hi Team! I'm contributing for the first time in akka. Can someone give me more insight on the issue akka/akka#30608 (akka/akka#30608). Thanks!
4 replies
Josep Prat
@jlprat
Hi @ennru we use Alpakka in our company and we came up with a couple of cornercases where no mocks really replicate the real behavior. We created this issue akka/alpakka#2743 . Any thoughts?
5 replies
Matthew de Detrich
@mdedetrich
@ennru @johanandren Can you hold of making a release until akka/alpakka#2746 is merged? I just realized right now that ListMultipartUploadResultCommonPrefixes is in fact a common datastructure that I want to reuse in another upcoming future PR (and since this breaks binary compatibility I want to merge it before a release)
Johan Andrén
@johanandren
Merged now :+1:
Matthew de Detrich
@mdedetrich
Many thanks!
Matthew de Detrich
@mdedetrich
@johanandren @ennru I am not sure what the plan is for the next release schedule for Alpakka but at least from my end akka/alpakka#2749 and akka/alpakka#2747 are the last remaining PR's for what I have been working on
Matthew de Detrich
@mdedetrich
@johanandren @ennru Apologies but I created a regression with the akka/alpakka#2747 PR (it turns out that some fields in the XML output are optional instead of mandatory if you do list bucket versions on a bucket that doesn't have versioning). I will fix this with a future PR and add a test for this
Johan Andrén
@johanandren
Alright, thanks for catching and the heads up.
Matthew de Detrich
@mdedetrich
PR for the fix is at akka/alpakka#2751, seems like I went down some S3 rabbit hole with this latest feature. Let me know if anything is needed, PR should be self descriptive.