Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
Ignasi Marimon-Clos
@ignasi35
Arsene
@Tochemey
Hello I would like to know how easy will be to switch to a different json serializer rather than the play-json.
jagadeesh83
@jagadeesh83
Hello team,
How to provide the security configurations to external kafka server?
Nikhil Arora
@nikhilaroratgo_gitlab
I am trying to create a dispatcher alias in my application.conf but I get the error "dispatcher has type STRING rather than OBJECT"
I don't want to create a separate dispatcher but create one and refer it with different names.
David Leonhart
@leozilla
Is it actually possible to subscribe to a persistent entity event stream without creating a topic? I would like to just react to the events of an entity w/o sending them to kafka
Ignasi Marimon-Clos
@ignasi35
:point_up: March 23, 2020 5:58 PM use the eventStream method in the persistentEntityRegistry. That produces a Source of all the events, though, at most you can filter by tag, but you can’t filter by persistent ID. Also, note that each client of an eventStream creates one or many polling instances on your database so it is not good to invoke eventStream in a unbounded fashion. Use sparingly.
brabo-hi
@brabo-hi
Hello, can we invoke a service by passing an object ? For example
myService.myFunction.invoke(MyCaseObject)
i am getting the following error message "Cannot resolve overloaded method 'invoke'"
But
myService.myFunction.invoke("my string message") is working
Sergey Morgunov
@ihostage
@brabo-hi What the result type of your method myFunction?
atropo
@atropo
Hi, I'm using sbt with lagom in java. In one, and only in one, of my modules I keep getting : package com.lightbend.lagom.javadsl.server does not exist. I've copied the sbt configuration from the other modules that work. What I'm doing wrong?
atropo
@atropo
Got it, I was missing the .enablePlugins(LagomJava). Lost hours on this :-(
Nayana Hettiarachchi
@devzer01
hi good morning/evening. hope everyone is staying safe. so i have a Scala application that uses Lagom. i can't find a usual
static void main() { }
how do i start the application from IDE like intelij? without making it as a SBT Task?
i see it uses some play. so can it be treated as a play application?
Sergey Morgunov
@ihostage

@devzer01

i see it uses some play. so can it be treated as a play application?

Absolutely yes. I never did that, but try to use play.core.server.DevServerStart for directly start.

jagadeesh
@jagadeeshcse83_gitlab
Hi Team,
I managed to deploy the lagom application(stand alone application)
But currently i am facing issues with service locator.. i guess.
Able to start the application in production mode but.. when i am trying to hit the application from another machine it is not responding.. however able to respond in the same machine. (tested with curl request)
Any guess have any idea.. ? what i missing ?
Arsene
@Tochemey
Hello lagom geeks. can someone educate me on this:
Sharding can be done in two ways, either manually by returning different tags based on information in the event, or automatically by returning a AggregateEventShards tag, which will tell Lagom to shard the tag used based on the entity’s persistence ID. It’s important to ensure all the events for the same entity end up with the same tag (and hence in the same shard), otherwise, event processing for that entity may be out of order, since the read side nodes will consume the event streams for their tags at different paces.
The reason I asked this is to see how I can manually set tag
Sergey Morgunov
@ihostage
@jagadeeshcse83_gitlab I think, that ServiceGateway in DevMode bind localhost instead 0.0.0.0 and you can't connect to it from another machine.
Nayana Hettiarachchi
@devzer01

hi, i am looking for some advice, i am building a schema denormaliser. normalized data in mysql and denormalized will be in a NoSQL server

  • (potential path of data)-> mysql-binlog -> kafka-connect -> (schema-registry) (avro) -> couchbase / mongodb

based on my experience i know with the following approach i will be likely to achieve the outcome

  • mysql-binlog -> kafka-connect -> consumer-to-mongodb -> map function in mongodb -> json document (denormalised data)

i feel this maybe a common problem that already have other solutions, can anyone give some advice? like do i need kafka-streams? do i need the schema-registry?

jagadeesh
@jagadeeshcse83_gitlab
@ihostage thanks reply
What are the change to be made on production mode to access from external server
I didn't understand the concept of service locator or service gateway. Can you help to share your the details.
jagadeesh83
@jagadeesh83
@ihostage i am still looking help on this this service locator and gateway in production mode..
jagadeesh83
@jagadeesh83
Some one can help me out to configure the service locator or service gateway in production mode ?
Raphaël Jammart
@raphael.jammart_gitlab
@jagadeesh83 For me, this post was/is really helpful. Hope it will help you too: http://klikix.com/lagom-kubernetes-setup-considerations/
jagadeesh
@jagadeeshcse83_gitlab
Thanks for the reply @raphael.jammart_gitlab 🙏
I am looking for the stand alone application deployment ... Not on kubernetes. It there reference..
Sergey Morgunov
@ihostage

@jagadeesh83 ServiceGateway is a primitive reverse proxy, that used only on DEV-Mode. You can't use it in production mode.
See this doc for details on how to configure bind address.

By default the Service Gateway binds to localhost. It is possible to change that address by adding this to your build.

In sbt:

lagomServiceGatewayAddress in ThisBuild := "0.0.0.0"

rudnitskiyas
@rudnitskiyas
Greetings. Does LagomTest support DI external service implemented in lagom, in native lagom service?
Andrey Ladniy
@AndreyLadniy
Hello. Question about Lagom 1.6. How to disable error log messages from BadRequest transport exceptions in ServiceCall?
BenCalus-RKA
@BenCalus-RKA
This message was deleted
Michael Mangeng
@visat1

Hi! I´ve updated my developement environment from Lagom 1.4.9 to 1.6.1 (i do not need the data in the db.. just the code update)... Now when i deploy the 1.6.1 based version i can see that akka discovery wants the discovery method to be defined. For 1.4.9 i used a eureka service locator for service discovery. How does this fit into akka-discovery?

from my understanding, there are 2 types of discovery procedures: lagom service discovery and akka cluster discovery, and that the most easy way would be to use the "AkkaDiscoveryServiceLocator" for lagom also - is this correct?

Sergey Morgunov
@ihostage
Yes. On Lagom 1.6.X ServiceLocator delegated logic to Akka Discovery.
Michael Mangeng
@visat1
@ihostage ok thank you.
Michael Mangeng
@visat1

One additional Question: Currently we're using spring cloud-gateway in the constellation: internet <-> nginx <-> sping-cloud-gw <-> lagom-services

Spring-cloud gatway does the discovery via eureka.

=> What do you use instead of the cloud-gateway to route requests to the correct service?

Ignasi Marimon-Clos
@ignasi35
You could use play with a LagomClientFactory. See the web-gateway at https://github.com/lagom/online-auction-scala/ for example...
Michael Mangeng
@visat1
thank you - will take a look
Sergey Morgunov
@ihostage
We use:
internet :point_right: OpenResty :point_right: K8S Ingress Controller :point_right: Lagom Services
But we plan to migrate from Ingress to NodePort.
Michael Mangeng
@visat1
For me it looks like LagomClientFactory is requiring a java interface for each supported service... ( https://javadoc.io/doc/com.lightbend.lagom/lagom-javadsl-integration-client_2.12/latest/index.html ). Is there a possibility to to dynamic invocation?
currently we're using: http://ip/<service-id>/<service-path> to invoke a call... with <service-id> a lookup up eureka is made... and <service-path> is the path which is forwarded to the service itself.
Ignasi Marimon-Clos
@ignasi35
My bad. I don’t know spring-cloud-gw and assumed it was a spring-based app with some code. If you want direct routing, they you need a way to map each path to a service and then a way to locate a running instance of that service. I`m not familiar with the SoA on that set of tools.
Michael Mangeng
@visat1
ok thank you.
mosaic-ashalatha-s
@mosaic-ashalatha-s
Hi guys, I am new to the Lagom. Can you please tell me how to implement ThirdParty scala Service descriptor to publish messages in java ?
Arsene
@Tochemey
Hello lagom folks. I would like to know how can I use the message broker with an additional route like PlayGrpc Router. I observe the only place to make use of the message broker is only at the rest api service definition
Ignasi Marimon-Clos
@ignasi35
:point_up: April 4, 2020 7:25 PM The Lagom Service.Descriptor is not a rest api service definition. Interllay it is implemented to transport the information as JSON-serialized messages over HTTP but that’s just coincidental. Having said that, the only place where you can describe a Topic is in the Service.Descriptor so, even if all your strict and streamed calls are implemented in gRPC, you still need the Service.Descriptor. Actually, for a Lagom service to be runnable you mist provide a Service.Descriptor with at least a name so you can’t work around from that.
Arsene
@Tochemey
@ignasi35 Thank
Nikhil Arora
@nikhilaroratgo_gitlab
Dear Lagom users ,Is there any detailed documentation which elaborates how and when to use role based clustering https://doc.akka.io/docs/akka/current/typed/cluster.html#node-roles. Based on the roles can I start a node which just runs ReadProcessor but not the Entities ?Basically, how would I scale ReadProcessor individually without having to distribute the entities ?