【问题标题】:The first element has not yet passed through in 5000 milliseconds第一个元素在 5000 毫秒内尚未通过
【发布时间】:2021-07-01 01:28:25
【问题描述】:

我是 lagom scala 的新手。创建了一个简单的 crud 来学习它的关键概念。首先,我使用sbt clean compile 编译了我的代码,它成功地编译了代码。 之后我尝试使用sbt clean runAll 命令运行该项目。有时服务启动没有任何问题。但有时我发现一条消息说

java.util.concurrent.TimeoutException: The first element has not yet passed through in 5000 milliseconds.
    at akka.stream.impl.Timers$Initial$$anon$1.onTimer(Timers.scala:62)
    at akka.stream.stage.TimerGraphStageLogic.onInternalTimer(GraphStage.scala:1601)
    at akka.stream.stage.TimerGraphStageLogic.$anonfun$getTimerAsyncCallback$1(GraphStage.scala:1590)
    at akka.stream.stage.TimerGraphStageLogic.$anonfun$getTimerAsyncCallback$1$adapted(GraphStage.scala:1590)
    at akka.stream.impl.fusing.GraphInterpreter.runAsyncInput(GraphInterpreter.scala:466)
    at akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:497)
    at akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:599)
    at akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:768)
    at akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:783)
    at akka.actor.Actor.aroundReceive(Actor.scala:534)
    at akka.actor.Actor.aroundReceive$(Actor.scala:532)
    at akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:690)
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:573)
    at akka.actor.ActorCell.invoke(ActorCell.scala:543)
    at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:269)
    at akka.dispatch.Mailbox.run(Mailbox.scala:230)
    at akka.dispatch.Mailbox.exec(Mailbox.scala:242)
    at java.util.concurrent.ForkJoinTask.doExec(Unknown Source)
    at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(Unknown Source)
    at java.util.concurrent.ForkJoinPool.runWorker(Unknown Source)
    at java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source)

谁能解释一下解决方法?提前致谢

【问题讨论】:

  • 嗨@md sam,欢迎来到SO,请按顺序提供代码,其他人可以帮助您。
  • 我观察到当我在系统中同时执行多项任务时会发生这种情况。我不确定这可能是显示上述消息的原因。
  • @aironman 我有带有服务 api 和 impl 的 lagom 项目。我不知道我应该在这里提供哪个代码。
  • 嗨!我从来没有对 Lagom 项目做过任何事情,所以我无法帮助你,但如果在 SO 中没有人可以帮助你,你也可以在 gitter.im/lagom/lagom?at=5e4faeaba0aa6629f5e1db9d 中提问

标签: scala akka microservices runtimeexception lagom


【解决方案1】:

我认为这是 read sideKafka client 的偏移超时之一。

如果您在一台机器上运行所有程序并且它正在挣扎,那么让事情运行、设置连接等可能需要更多时间,因此请尝试将这些超时调整为更高的值,看看是否有帮助。

【讨论】:

  • 如何将超时设置为更高的值?
  • 将这些链接的设置放入您的application.conf
猜你喜欢
  • 2020-05-13
  • 2020-03-10
  • 1970-01-01
  • 2020-04-05
  • 2021-05-13
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2019-03-11
相关资源
最近更新 更多