Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
AltiorBahA
@AltiorBahA
The stackoverflow link of my question is here
Chris Bowden
@cbcwebdev
@AltiorBahA if you are publishing myserviceimpl in an idiomatic way, you probably need a %% in there. you dont need to enable the lagom plugin on the external project settings. you shouldnt need to inform it to skip publishing either. not sure what you're doing with guice, sometimes i do have reason to modify dependencies / settings on an external proj.
Srepfler Srdan
@schrepfler
looks like play-grpc-generators_2.13 is not published to central yet
Arsene Tochemey Gandote
@Tochemey
@schrepfler the play-grpc-generator is an sbt plugin and sbt plugin solely run on scala 2.12.
3 replies
Joe Koberg
@jkoberg
Hello all. I am consuming SQS messages inside a service with an Alpakka SQSSource flow that I start in the body (run at constructor time) of the Lagom service - and after a while it stops consuming messages
1 reply
and thoughts on where I might be going wrong? Do I need to do anything else to keep a long-lived (many weeks) flow up?
Levi Ramsey
@leviramsey
Have you tried wrapping it in a RestartSource/RestartFlow/RestartSink?
Dheeraj Karande 🇮🇳
@dheerajkarande_twitter
Hi all,
Is there any way we can use application conf values inside logback.xml file in Lagom framework?
For Play we have something like
play.logger.includeConfigProperties=true
https://www.playframework.com/documentation/2.8.x/SettingsLogger#Including-Properties
Nishchal Kutarekar
@nishchalk
Hi All,
Cassandra offsetstore is not getting populated for external cassandra, and because of this messages are not published to kafka topic.
But the same is working fine when I'm using embedded cassandra. I'm running lagom in development (both for external, embedded cassandra) using mvn lagom:runAll
Am I missing some config? How should I got about debugging the cause?
BodhitavyaKashyap
@BodhitavyaKashyap

Hi everyone,
I am using mysql via jpa to store read-side data for my lagom project implemented in java. The tables for readside are created by jpa but the data is not getting populated in the tables . I am following shopping cart example as well as mixed-persistence example . I have cassandra as write -side DB. I am doing everything the same way as explained in the examples .I must be missing something but if someone has already faced the same issue, can help me here.

https://github.com/lagom/lagom-samples/tree/878907a155acd42c4d4260e9abdc54e2e4f5125f/mixed-persistence/mixed-persistence-java-sbt

https://github.com/lagom/lagom-samples/blob/1.6.x/shopping-cart/shopping-cart-java/shopping-cart/src/main/java/com/example/shoppingcart/impl/ShoppingCartReportProcessor.java

6 replies
Nishchal Kutarekar
@nishchalk
Found the problem with Cassandra offsetstore not getting updated for external Cassandra: we had <kafkaEnabled> was set to false in our pom, we were using it to disable bedded Kafka in dev mode. But in prod mode when this is false, topicProducer doesn't produce anything
Vincent Canuel
@vcanuel
Hi, we want to moving our Cassandra cluster to the new Serverless service from DataStax. Our first benchmark indicates that there are 250 reads / second => 1M per hour ! (on idle with no reads or writes requests). Do you think, this is normal ?
9 replies
(We only using cassandra for persisting events and MySql for the read side)
Nishchal Kutarekar
@nishchalk
Hi all, in our lagom deployment we are seeing a delay of 5 seconds between publishing and receiving of events. How to reduce this? Can you please help
3 replies
Srepfler Srdan
@schrepfler
we're noticing embedded Cassandra has issues on JDK15, any plans to address this? There was some conversation to move to testcontainers some time back...
Nathan Ostgard
@noonat
Is it possible to use Jackson for serialization in the service trait? I've been able to switch to Jackson everywhere else, but when I try to use it there, it complains about missing MessageSerializer implicits on the pathCalls.
Joe Koberg
@jkoberg
Anyone experienced problems with sbt runAll under windows with a new project?
I get java.lang.UnsatisfiedLinkError: C:\Users\jkobe\AppData\Local\Temp\jna-101190673\jna8952672481501973987.dll: %1 is not a valid Win32 application from what I assume is the bundled cassandra
Joe Koberg
@jkoberg
@schrepfler I'm currently having problems with the embedded cassandra on windows, and have had ongoing issues starting in dev mode on anything other than java 8
21 replies
It's a really bad first experience esp. when I am trying to evangelize the framework
schrepfler
@schrepfler:matrix.org
[m]
We’re running with latest openjdk 11 IIRC
schrepfler
@schrepfler:matrix.org
[m]
is there any example of Lagom using caffeine properly using the module system?
schrepfler
@schrepfler:matrix.org
[m]
maybe by using the play CaffeineCacheModule and injecting CacheManagerProvider? Not sure if that's the best strategy, especially if I want to populate it on the fly by providing a supplier that invoke's the service interface (which is CompletableStage and the get will want a resolved entity)
schrepfler
@schrepfler:matrix.org
[m]
when autogenerating the jpa tables I get sequence_offset bigint but it needs to be of bytea, is there anywhere where this is managed declaratively?
(can this be because my id's are UUID's?)
Bett B.K.
@bettbenard

Having problems implementing pac4j-lagom (java) OAuth in my project:

Configure your OAuth 2 library with your client_id, client_secret, and redirect_uri. Tell it to use https://launchpad.37signals.com/authorization/new to request authorization and https://launchpad.37signals.com/authorization/token to get access tokens

Patrick Culligan
@pculligan

Hi Team; I've hunted the internet, this channel, and have yet to find a clue, so here goes:

Kafka Server closed unexpectedly.

...has become the bane of my existence. I am 100% sure it's not a problem in lagom 1.6.4, but in my use of it. It's possible it's this machine (maybe it's been crippled somehow by IT). However I need to get to the bottom of it.

  • There is no folder "log4j_output" at <your-project-root>/target/lagom-dynamic-projects/lagom-internal-meta-project-kafka/target/log4j_output
  • There is no error reported by runAll above that "closed" message.
  • I have deleted the <your-project-root>/target/lagom-dynamic-projects/lagom-internal-meta-project-kafka folder in case it was zookeeper.
  • I have done sbt clean
  • I have done this in Java 8 and 11.

Might I ask advice on tracking this down?

4 replies
schrepfler
@schrepfler:matrix.org
[m]
SDKMan ❤️
Joe Koberg
@jkoberg
Has anyone struggled with this: Reams and reams of akka cluster logs.... each line hundreds of characters long, printing constantly.... but when your app doesn't work, there's zero information available about what may be going wrong
Database call might be failing, but zero logging that says so
No information about why actors may not have responded to a message
schrepfler
@schrepfler:matrix.org
[m]
Yes
Joe Koberg
@jkoberg
any hints on config changes ?
I have basic entity behavior that's not working, and nothing to go on. Messages just disappear. It really looks bad to my boss
schrepfler
@schrepfler:matrix.org
[m]
Not really, at the moment it’s touch and go. I definitely agree it would be nice if there would be more errors bubbling up if something happens at any stage of the workers lifecycle with more detail
Remember to put logging in your code at least so that you know where in the flow you are
Also put some metrics in place, maybe invest in cinnamon or Kamon, that can sometime identify actor processing times although not sure if it works with Lagom
Nathan Ostgard
@noonat
I'm attempting to tweak the consistency settings, and I've tried setting both cassandra-query-journal.eventual-consistency-delay and akka.persistence.cassandra.events-by-tag.eventual-consistency-delay in my <x>-impl/src/main/resources/application.conf files. However, when I start the service with sbt runAll, I still see akka.persistence.cassandra.query.EventsByTagStage logs saying "starting with EC delay 5000ms", and the timing doesn't seem to have changed at all for events being picked up in my read-side processor. Any suggestions as to what I might be doing wrong?
3 replies
Fredrick Oluoch
@menty44
hey guys
am getting this error
Caused by: com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /127.0.0.1:4000: java.lang.UnsupportedOperationException: can't get field offset on a hidden class: private final org.apache.cassandra.db.ClusteringComparator org.apache.cassandra.db.ClusteringComparator$$Lambda$157/0x0000000800d891e0.arg$1
after running mvn lagom:runAll
please advice
Nishchal Kutarekar
@nishchalk

Hi All,
I'm using shopping-cart example from lagom-samples. While running on single node cluster I observe that, on making multiple concurrent requests akka.actor.default-dispatcher count (observed from visualVM) keeps increasing (proportional to concurrent requests) and they remain in PARK state even after request is served.

is this an expected behaviour? How do we control this and reuse the same actors or kill the actors after request has been served.

schrepfler
@schrepfler:matrix.org
[m]
going back to my UUID question, I can see in lagom-persistence-jdbc-core that sequebceOffset is defined as column[Option[Long]]
(reference: com.lightbend.lagom.internal.persistence.jdbc.SlickOffsetStore.OffsetStore), when I run my read side on postgresql this fails and I need to drop the table and convert from bigint into bytea, can this be because my key's are UUID and using the native postgres uuid type?
    @Id
    @Type(type="pg-uuid")
    private UUID eventId;
SynappsGiteau
@SynappsGiteau
Hello everyone,
We have been using Lagom in production for a few months and we would like to optimize several things:
  • (Most importantly) RAM usage (for obvious cost reasons)
  • the startup time of the services
  • the warm-up time of the services (related to the JIT compilation)
    We would like to know if it is possible with Lagom (and if someone has already explored this topic) to use the Image Native technology with GrallVM, or to configure another ahead-of-time (AOT) compilation mechanism
    For information, we run our services on a Kubernetes environment.
    Thanks for your feedback
schrepfler
@schrepfler:matrix.org
[m]
Congratulations on the release!
manavgupta08
@manavgupta08
Hi All, each of my lagom services in production are making millions of queries per couple of hours to cassandra. That leads to huge cost and cassandra running out of resources(outage). Any idea what part of Lagom is making these queries ? and how to reduce/manage frequency of these queries ?
manavgupta08
@manavgupta08
is Lagom dead ? I don't see much action or response from lightbend team on this forum or elsewhere. I have invested quite a bit to build production app for my start up . I am bit worried .
2 replies
Vincent Canuel
@vcanuel
Thanks for the enlightenment, I think Lagom could also improves its current stack with features like ‘saga pattern’ implementation