मैं लैगोम, इलास्टिक्स खोज के लिए नया हूं, मैं लैगॉम, इलास्टिक्स खोज, स्कैला और कैसेंड्रा का उपयोग कर रहा हूं। सब कुछ ठीक है, लेकिन जब मैं पोस्टमैन के माध्यम से जोंस डेटा पोस्ट करता हूं, तो डेटा कैसेंड्रा में जाता है, लेकिन इलास्टिक्स खोज के लिए नहीं और मुझे एक चेतावनी और एक त्रुटि मिल रही है नीचे

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=search-impl-application] - विफलता के कारण बाधित विषय सदस्यता: [java.lang. IllegalStateException: सर्विस इलास्टिक-सर्च सर्विस लोकेटर द्वारा नहीं मिला] 12:22:10.688 [त्रुटि] 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.la . पर सर्विस लोकेटर को सर्विस इलास्टिक-सर्च नहीं मिला gom.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) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) at akka.dispatch .BatchingExecutor$BlockableBatch.$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) at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:91) at akka.dispatch.Ta skInvocation.run(AbstractDispatcher.scala:40) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44) at akka.dispatch.forkjoin.ForkJoinTask.doExec.forkJoinTask.forkJoin. .ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJava:107)

[चेतावनी] com.lightbend.lagom.internal.scaladsl.registry.ServiceRegistryServiceLocator [] - सेवा का नाम = [लोचदार-खोज] नहीं मिला। संकेत: शायद यह पंजीकृत नहीं था?

कोई मदद??

0
Surya 26 फरवरी 2019, 09:58

1 उत्तर

सबसे बढ़िया उत्तर

देखें https://www.lagomframework .com/documentation/1.4.x/scala/ServiceLocator.html#Communicating-with-external-services अतिरिक्त सेवाओं के साथ विकास मोड सेवा लोकेटर को कॉन्फ़िगर करने के बारे में जानकारी के लिए।

उदाहरण के लिए, इसे ऑनलाइन नीलामी स्काला उदाहरण प्रोजेक्ट में इस प्रकार कॉन्फ़िगर किया गया है:

// 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")

इसके प्रभावी होने के लिए आपको अपना एसबीटी कॉन्फ़िगरेशन पुनः लोड करना होगा और अपनी सेवाओं को पुनरारंभ करना होगा।

0
Tim Moore 27 फरवरी 2019, 01:09