com.lightbend.lagom.internal.broker.kafka.KafkaSubscriberActor - PullRequest
Новая
       31

com.lightbend.lagom.internal.broker.kafka.KafkaSubscriberActor

0 голосов
/ 26 февраля 2019

Я новичок в lagom ,asticsearch, я использую lagom ,asticsearch, scala и cassandra. Все хорошо, но когда я отправляю данные json через почтальон, данные отправляются на cassandra, но не на эластичный поиск, и я получаю сообщение об ошибке.предупреждение и как показано ниже

12: 22: 10.688 [ошибка] com.lightbend.lagom.internal.broker.kafka.KafkaSubscriberActor [sourceThread = search-impl-application-akka.actor.default-dispatcher-5, akkaTimestamp = 06: 52: 10.688UTC, akkaSource = akka.tcp: //search-impl-application@127.0.0.1: 51584 / user / KafkaBackoffConsumer1-customerTopic / KafkaConsumerActor1-customerTopic, приложение sourceActorSystem = =- Подписка на тему прервана из-за сбоя: [java.lang.IllegalStateException: поиск эластичной службы не найден локатором службы] 12: 22: 10.688 [error] akka.actor.OneForOneStrategy [sourceThread = search-impl-application-akka.actor.default-dispatcher-5, akkaTimestamp = 06: 52: 10.688UTC, akkaSource = akka: // search-impl-application / user / KafkaBackoffConsumer1-customerTopic / KafkaConsumerActor1-customerTopic, sourceActorSystem = search-impl-application] - Поиск эластичной службы не найден локатором службы java.lang.IllegalStateException: Поиск эластичной службы не найден локатором службы на com.lightbend.lagom.internal.client.ClientServiceCallInvoker. $ anonfun $ doInvoke $ 4 (ClientServiceCallInvoker.scala: 75) на scala.util.Success. $ anonfun $ map $ 1 (Try.scala: 251) на scala.util.Success.map (Try.scala: 209)на scala.concurrent.Future. $ anonfun $ map $ 1 (Future.scala: 289) на scala.concurrent.impl.Promise.liftedTree1 $ 1 (Promise.scala: 29) на scala.concurrent.impl.Promise. $ anonfun $ transform$ 1 (Promise.scala: 29) в scala.concurrent.impl.CallbackRunnable.run (Promise.scala: 60) в akka.dispatch.BatchingExecutor $ AbstractBatch.processBatch (BatchingExecutor.scala: 55) в блоке akka.dispatch.BatchingExecutor $. $ anonfun $ run $ 1 (BatchingExecutor.scala: 91) в scala.runtime.java8.JFunction0 $ mcV $ sp.apply (JFunction0 $ mcV $ sp.java: 12) в scala.concurrent.BlockContext $ .withBlockContext (BlockContext.scala: 81) в файле akka.dispatch.BatchingExecutor $ BlockableBatch.run (BatchingExecutor.scala: 91) в файле akka.dispatch.TaskInvocation.run (AbstractDispatcher.scala: 40) в файле akka.dispatch.exe(ForkJoinExecutorConfigurator.scala: 44) по адресу akka.dispatch.forkjoin.ForkJoinTask.doExec (ForkJoinTask.java:260) по адресу akka.dispatch.forkjoin.ForkJoinPool $ WorkQue.ForkJoinPool.runWorker (ForkJoinPool.java:1979) по адресу akka.dispatch.forkjoin.ForkJoinWorkerThread.run (ForkJoinWorkerThread.java:107)

[warn] com.lightbend.Serg.Serg.] - Имя службы = [эластичный поиск] не найден.Подсказка: Может быть, это не было зарегистрировано?

любая помощь ??

1 Ответ

0 голосов
/ 27 февраля 2019

См. https://www.lagomframework.com/documentation/1.4.x/scala/ServiceLocator.html#Communicating-with-external-services для получения информации о настройке локатора служб режима разработки с дополнительными службами.

Например, это то, как он настроен в примере проекта Online Auction Scala : 

// register 'elastic-search' as an unmanaged service on the service locator so that at 'runAll' our code
// will resolve 'elastic-search' and use it. See also com.example.com.ElasticSearch
lagomUnmanagedServices in ThisBuild += ("elastic-search" -> "http://127.0.0.1:9200")

Вам потребуется перезагрузить конфигурацию sbt и перезапустить службы, чтобы это вступило в силу.

...