We are using Lagom framework 1.6.2 in production. The micro-service produces to 3 kafka topics and uses TopicProducer.taggedStreamWithOffset as a producer from persistentEntities eventStream.
We are experiencing an issue where the messages are not produced for 1 topic. The other 2 topics from the same event are produced successfully. The timeuuidoffset from the offsetstore for the eventprocessorid where the messages are not producing is stale and is not producing new kafka messages.
- What determines the offsetstore table, timeuuidoffset value for partitions.
Please let us know how to proceed ?