@mm
I do not beleive this is possible with a current API.
TopicProducer is only API to get Topic<Message>. With taggedStreamWithOffset, AggregateEventTag<Event> is used to query offset for publish and enforces explicit event type to use (only one).
In your case you need to provide two event types.
registry.eventStream(tag, offset) could be used to create akka stream per event type and then to do akka stream merge but getting the offset is a problem.
Maybe I’m wrong but it looks like that.
If you require merging of two kafka topics into one you could use kafka stream: Kafka stream join
It is not Lagom specific and requires additional dependencies.