Create Source from Lagom kafka subscriber

Lagom
, ,
1

Hi, we have a lagom service which consumes from two different topics and process records. So our subscriber looks like

realtimeScanKafka.cloudEventTopic.subscribe

        topic1.subscribe.atLeastOnce(
          Flow
            .fromFunction(consumeEvent1)
        )

       topic2.subscribe.atLeastOnce(
          Flow
            .fromFunction(consumeEvent2)
        )

Now we would like to merge both of these streams before consuming as a single Akka stream. Is that possible with atLeastOnce?
Docs suggest that atMostOnceSource will return a Source back but we would like the same behavior with atLeastOnce.

Thank you