I’m using Lagom 1.6. In one microservice I subscribe to a topic of another microservice like this: customerService.customerEventsTopic().subscribe // And subscribe to it with at least once processing semantics. .withMetadata .withGroupId("ISTWriter") .atLeastOnce( Flow[Mess…

Kafka consumer failed to commit message received

aklikic (Alan Klikic) February 12, 2020, 5:26pm 2

Hi,

Check this topic.

Hole this helps.

Br,
Alan

Topic		Replies	Views
Recovering from KafkaSubscriberActor caused by ConsumerFailed Lagom Message Broker API kafka	6	3057	January 31, 2019
Topic Subscriber extreme delay in receiving messages in Development Lagom Message Broker API java , kafka	3	981	July 23, 2021
Prevent Lagom Kafka consumer restart Lagom Message Broker API	0	990	March 23, 2019
Lagom service on startup requires to publish message on Kafka topic Lagom java , kafka	0	507	February 24, 2021
Consumer interrupted with WakeupException after timeout. Message: null Lagom	33	8408	March 14, 2019