Как подключить автономный клиент lagom к событиям kafka? - PullRequest
Новая
       68

Как подключить автономный клиент lagom к событиям kafka?

0 голосов
/ 03 апреля 2019

У меня есть служба lagom, публикующая свои события на тему кафки. У меня также есть отдельный клиент lagom для этой службы, и я хотел бы, чтобы он подписывался на тему событий.

Вот как я создаю клиента: 

    val lagomClientFactory: StandaloneLagomClientFactory = new StandaloneLagomClientFactory("A")
      with StaticServiceLocatorComponents
      with AhcWSComponents {
      override def staticServiceUri: URI = URI.create(...)
    }

    val client = lagomClientFactory.serviceClient.implement[MyService]

Я попытался взять клиента и позвонить: 

client.myEvents.subscribe.atLeastOnce(Flow[MyEvent].mapAsync(1) {
   ...
}

Но, похоже, ничего не поделаешь. Можно ли подключить автономный клиент lagom к теме кафки? Любая помощь будет оценена

...