4

我玩过lagom-scala-word-countActivator 模板，我被迫终止应用程序进程。从那时起，嵌入式 kafka 就不起作用了——这个项目和我创建的每一个新项目都变得无法使用。我试过了：

  • 运行 sbt clean，删除嵌入的 Kafka 数据
  • 创建全新的项目（来自其他激活器模板）
  • 重新启动我的机器。

尽管如此，我还是无法让 Lagom 工作。在第一次启动期间，我在日志中得到以下几行：

[warn] o.a.k.c.NetworkClient - Error while fetching metadata with correlation id 1 : {wordCount=LEADER_NOT_AVAILABLE}
[warn] o.a.k.c.NetworkClient - Error while fetching metadata with correlation id 2 : {wordCount=LEADER_NOT_AVAILABLE}
[warn] o.a.k.c.NetworkClient - Error while fetching metadata with correlation id 4 : {wordCount=LEADER_NOT_AVAILABLE}
[warn] a.k.KafkaConsumerActor - Consumer interrupted with WakeupException after timeout. Message: null. Current value of akka.kafka.consumer.wakeup-timeout is 3000 milliseconds
[warn] a.k.KafkaConsumerActor - Consumer interrupted with WakeupException after timeout. Message: null. Current value of akka.kafka.consumer.wakeup-timeout is 3000 milliseconds

下一次启动会导致：

[info] Starting Kafka
[info] Starting Cassandra
....Kafka Server closed unexpectedly.
....
[info] Cassandra server running at 127.0.0.1:4000

我已经在https://gist.github.com/szymonbaranczyk/a93273537b42aafa45bf67446dd41adb上发布了来自 lagom-internal-meta-project-kafka 的完整 server.log 。

是否有可能某些损坏的嵌入式 Kafka 数据全局存储在我的电脑上并导致此问题？

4

1 回答 1

12

为了将来参考，正如詹姆斯在评论中提到的那样，您必须删除lagom-internal-meta-project-kafka. target/lagom-dynamic-projects我不知道为什么它没有被自动删除。

于 2018-02-21T17:42:44.430 回答