我玩过 lagom-scala-word-count Activator 模板,我被迫终止了应用程序进程。从那以后嵌入式 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 数据全局存储在我的电脑上并导致这种情况?

    最佳答案

    为了将来引用,正如 James 在评论中提到的,您必须删除 lagom-internal-meta-project-kafka 中的文件夹 target/lagom-dynamic-projects 。我不知道为什么它不会被自动删除。

    10-08 14:31