Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
Sumit Kumar Sahoo
@sahoosumit
Can any one help me after production move we are trying to add another field (cType) in entity class but we getting issue for old data like : com.esotericsoftware.kryo.KryoException: Unable to find class: 9f9cec48805251b1676a21c
Serialization trace:
cType at com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultClassResolver.java:160)
at com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(DefaultClassResolver.java:133)
at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:693)
at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:118)
at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:543)
Robert D. Blanchet Jr.
@blanchet4forte
before lagom 1.6 we used play-json to serialize scala Enumeration enums. with lagom 1.6 and Akka Persistence typed.. Jackson doesn't properly handle Enumeration. What is a good path forward? I prefer using Enumeration over sealed case objects.
Nikhil Arora
@nikhilaroratgo_gitlab
Hello Guys,Is there any way to configure dispatcher and snapshot-after configuration per PersisentityEntity specific?
Ignasi Marimon-Clos
@ignasi35
:point_up: March 11, 2020 8:13 PM I think Jackson supports multiple serialization formats for scala’s Enumeration.
matrixbot
@matrixbot
Miuler Hi people, any news in the world of lagom?
Miuler How can we encourage more the use of lagom? any opensource tool built with lagom?
Arsene
@Tochemey
@Miuler_twitter weat Namely with few customisation are using lagom for our ES/CQRS driven application. Lagom is great a tool for anyone who really understands the need of microservice, event sourcing and co. I don't think we need to encourage people to use it. It did not take me 2 mn to discover lagom. Just by typing microservice framework in scala and bam.
Any aficianado of great engineering can easily discover lagom.
Arsene
@Tochemey
@blanchet4forte The same enumaration serializer you had can still work in the one 1.6
Also bear in mind the framework is a bit flexible for customisation if you are willing to take that route
jagadeesh583
@jagadeesh583

Hi Team,
I have 3 micro services for my project
1) Consume External API services using Kafka consumer (service#3)
2) Produce Kafka topic and save into Cassandra db (service#2)
3) API to hit service#2 and which can extended to our external clients (service#1)

How many servers are required for above scenario #1service , #2service , #3service , Cassandra and Kafka server ?

Tuhin Dey
@Heisenbug-16
Is there a way to register some handler when a websocket connection breaks ?
Tuhin Dey
@Heisenbug-16
Got it. Please ignore the above question. 😅
jagadeesh83
@jagadeesh83

@jagadeesh583 sbt dist will give you a jar

Thank you @jkoberg but i am using mvn build

jagadeesh83
@jagadeesh83
Is there any guide ?
i am trying with https://github.com/TimMoore/lagom-mvn-standalone
but still facing the port related issue
Altern Egro
@alternegro
Hello, I'm trying to migrate to 1.6.1 from 1.5.0. The instructions say to migrate to the latest 1.5.x version, which is 1.5.5, but I can't seem to find any instructions on doing the upgrade. I've been able to get my app to compile for 1.6.1 simply by following the deprecation warnings, but I can't confirm everything works correctly because some tests are throwing StackOverflow errors. I've looked at the seed project and it seems they haven't been fully migrated yet because the tests throw kafka_native errors out the box. Any comprehensive guidance on migration will be greatly appreciated.
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?